feat():编辑卡夫卡代码

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：张腾

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);
+
+
     }
 }

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>