 Aaaaaaaa
|
e6e7e58f95
|
移除冗余代码并优化Kafka配置
- 删除了KafkaConstants、KafkaConsumerConfig和KafkaProviderConfig类，这些类已被移动到其他项目中
-简化了KafkaConfig类，移除了其中的kafkaProducer方法，该方法已被移动到其他类中
- 在MqttTest类中更新了Kafka主题的硬编码值
- 移除了oneMse类，该类用于测试，目前不再需要
- 在ProtocolApplication的main方法中添加了一个空的System.out.println语句，用于调试或日志记录
|
2024-10-07 14:22:46 +08:00 |
|
Aaaaaaaa
|
b2c16300f4
|
Merge remote-tracking branch 'origin/master'
# Conflicts:
# cloud-common/cloud-common-kafka/pom.xml
# cloud-common/cloud-common-kafka/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
|
2024-10-02 09:58:47 +08:00 |
|
Aaaaaaaa
|
b07b7a1d2d
|
添加Kafka消息队列配置和常量类
- 新增KafkaConstants类，定义Kafka主题和消费组常量
- 新增KafkaConsumerConfig类，配置Kafka消费者
- 新增KafkaProviderConfig类，配置Kafka生产者
- 添加AutoConfiguration.imports文件，导入Kafka配置类
- 创建cloud-common-kafka模块的pom.xml文件，添加依赖
|
2024-10-02 09:58:09 +08:00 |
 张腾
|
87b3eccff5
|
feat():更新最新代码
|
2024-10-02 09:12:44 +08:00 |