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