From af798f18e5be83e40197e8358586dc04b8c3742f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E8=85=BE?= <3467447354@qq.com> Date: Mon, 30 Sep 2024 16:52:26 +0800 Subject: [PATCH 1/2] =?UTF-8?q?feat():=E7=BC=96=E8=BE=91=E5=8D=A1=E5=A4=AB?= =?UTF-8?q?=E5=8D=A1=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/muyu/carData/CarDataApplication.java | 3 --- .../java/com/muyu/carData/consumer/MyKafkaConsumer.java | 8 ++++++-- pom.xml | 2 +- 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/CarDataApplication.java b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/CarDataApplication.java index 50b42da..b4c997b 100644 --- a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/CarDataApplication.java +++ b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/CarDataApplication.java @@ -4,9 +4,6 @@ import com.muyu.carData.listener.MyListener; import com.muyu.common.security.annotation.EnableMyFeignClients; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.cloud.openfeign.EnableFeignClients; - -import javax.swing.*; /** * @Author：张腾 diff --git a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/consumer/MyKafkaConsumer.java b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/consumer/MyKafkaConsumer.java index a661bfc..58f4b6e 100644 --- a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/consumer/MyKafkaConsumer.java +++ b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/consumer/MyKafkaConsumer.java @@ -16,7 +16,7 @@ import java.time.Duration; import java.util.Collection; /**卡夫卡消费者 - * @Author：张腾 + * @Author：张腾臭狗熊 * @Package：com.muyu.carData.consumer * @Project：cloud-server-8 * @name：MyKafkaConsumer @@ -29,7 +29,7 @@ public class MyKafkaConsumer implements InitializingBean { @Autowired private KafkaConsumer kafkaConsumer; - private final String topicName = "test"; + private final String topicName = "carJsons"; @Override public void afterPropertiesSet() throws Exception { @@ -51,5 +51,9 @@ public class MyKafkaConsumer implements InitializingBean { } }); thread.start(); + + log.info("启动线程结束监听topic:{}",topicName); + + } } diff --git a/pom.xml b/pom.xml index b30f0df..b0ebadf 100644 --- a/pom.xml +++ b/pom.xml @@ -10,7 +10,7 @@ muyu http://www.muyu.vip - 若依微服务系统 + 智能车联系统 3.6.3 From 87b3eccff57300d73bc24b73511b2f5ad1fe14e6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E8=85=BE?= <3467447354@qq.com> Date: Wed, 2 Oct 2024 09:12:44 +0800 Subject: [PATCH 2/2] =?UTF-8?q?feat():=E6=9B=B4=E6=96=B0=E6=9C=80=E6=96=B0?= =?UTF-8?q?=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cloud-common/cloud-common-kafka/pom.xml | 27 +++++++++++++++++++ .../com/muyu}/kafkaconfig/KafkaConfig.java | 2 +- ...ot.autoconfigure.AutoConfiguration.imports | 1 + cloud-common/pom.xml | 1 + cloud-modules/cloud-modules-carData/pom.xml | 6 ++--- .../carData/consumer/MyKafkaConsumer.java | 7 ++--- 6 files changed, 35 insertions(+), 9 deletions(-) create mode 100644 cloud-common/cloud-common-kafka/pom.xml rename {cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/config => cloud-common/cloud-common-kafka/src/main/java/com/muyu}/kafkaconfig/KafkaConfig.java (98%) create mode 100644 cloud-common/cloud-common-kafka/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports diff --git a/cloud-common/cloud-common-kafka/pom.xml b/cloud-common/cloud-common-kafka/pom.xml new file mode 100644 index 0000000..6bd82ac --- /dev/null +++ b/cloud-common/cloud-common-kafka/pom.xml @@ -0,0 +1,27 @@ + + + 4.0.0 + + com.muyu + cloud-common + 3.6.3 + + + cloud-common-kafka + + + 17 + 17 + UTF-8 + + + + + org.apache.kafka + kafka-clients + 3.0.0 + + + diff --git a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/config/kafkaconfig/KafkaConfig.java b/cloud-common/cloud-common-kafka/src/main/java/com/muyu/kafkaconfig/KafkaConfig.java similarity index 98% rename from cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/config/kafkaconfig/KafkaConfig.java rename to cloud-common/cloud-common-kafka/src/main/java/com/muyu/kafkaconfig/KafkaConfig.java index bcf8999..393ccbb 100644 --- a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/config/kafkaconfig/KafkaConfig.java +++ b/cloud-common/cloud-common-kafka/src/main/java/com/muyu/kafkaconfig/KafkaConfig.java @@ -1,4 +1,4 @@ -package com.muyu.carData.config.kafkaconfig; +package com.muyu.kafkaconfig; import org.apache.kafka.clients.consumer.KafkaConsumer; import org.apache.kafka.clients.producer.KafkaProducer; diff --git a/cloud-common/cloud-common-kafka/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/cloud-common/cloud-common-kafka/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports new file mode 100644 index 0000000..24563f7 --- /dev/null +++ b/cloud-common/cloud-common-kafka/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports @@ -0,0 +1 @@ +com.muyu.kafkaconfig.KafkaConfig diff --git a/cloud-common/pom.xml b/cloud-common/pom.xml index a7a40be..60e1c14 100644 --- a/cloud-common/pom.xml +++ b/cloud-common/pom.xml @@ -21,6 +21,7 @@ cloud-common-xxl cloud-common-rabbit cloud-common-saas + cloud-common-kafka cloud-common diff --git a/cloud-modules/cloud-modules-carData/pom.xml b/cloud-modules/cloud-modules-carData/pom.xml index 53d679b..9824751 100644 --- a/cloud-modules/cloud-modules-carData/pom.xml +++ b/cloud-modules/cloud-modules-carData/pom.xml @@ -83,9 +83,9 @@ 2.9.3 - org.apache.kafka - kafka-clients - 3.0.0 + com.muyu + cloud-common-kafka + 3.6.3 org.apache.iotdb diff --git a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/consumer/MyKafkaConsumer.java b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/consumer/MyKafkaConsumer.java index 58f4b6e..8d0aecc 100644 --- a/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/consumer/MyKafkaConsumer.java +++ b/cloud-modules/cloud-modules-carData/src/main/java/com/muyu/carData/consumer/MyKafkaConsumer.java @@ -16,7 +16,7 @@ import java.time.Duration; import java.util.Collection; /**卡夫卡消费者 - * @Author：张腾臭狗熊 + * @Author：张腾 * @Package：com.muyu.carData.consumer * @Project：cloud-server-8 * @name：MyKafkaConsumer @@ -43,10 +43,7 @@ public class MyKafkaConsumer implements InitializingBean { for (ConsumerRecord consumerRecord : consumerRecords) { //从consumerRecord中获取消费数据 String value = consumerRecord.value(); - log.info("从Kafka中消费的原始数据：{}",value); - //转换为java对象 - Student stu = JSONUtil.toBean(value, Student.class); - log.info("消费数据转换为Java对象：{}",stu); + log.info("从Kafka中消费的原始数据===============>>：{}",value); } } });