src/main/java/com/whyc/config/KafkaConfig.java
@@ -14,7 +14,7 @@ @Bean public NewTopic batchTopic() { //return new NewTopic("topic_device_data",3,(short)3); return new NewTopic("topic_device_data2",1,(short)1); return new NewTopic("topic_device_data2",3,(short)1); } //@KafkaListener(topics = "topic_device_data")
