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] =?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 @@
 
     <name>muyu</name>
     <url>http://www.muyu.vip</url>
-    <description>若依微服务系统</description>
+    <description>智能车联系统</description>
 
     <properties>
         <muyu.version>3.6.3</muyu.version>