需求修改

pro-base/src/main/java/com/idea/kafka/KafkaConsumer.java

@@ -16,22 +16,22 @@ import org.springframework.stereotype.Component;
  * @see [相关类/方法]
  * @since [产品/模块版本]
  */
-@Component
-@AllArgsConstructor
-@Slf4j
+//@Component
+//@AllArgsConstructor
+//@Slf4j
 public class KafkaConsumer {
 
 
-    @KafkaListener(topics = "lifeline_handle", groupId = "lifeline")
-    public void rawData(ConsumerRecord consumerRecord) {
-        Object value = consumerRecord.value();
-        Object offset = consumerRecord.offset();
-
-        if (null == value) {
-            System.err.println("kafka消费数据为空");
-        }
-        System.out.println("通行证: OffSet -> "+offset+", data -> "+(String) value);
-    }
+//    @KafkaListener(topics = "lifeline_handle", groupId = "lifeline")
+//    public void rawData(ConsumerRecord consumerRecord) {
+//        Object value = consumerRecord.value();
+//        Object offset = consumerRecord.offset();
+//
+//        if (null == value) {
+//            System.err.println("kafka消费数据为空");
+//        }
+//        System.out.println("通行证: OffSet -> "+offset+", data -> "+(String) value);
+//    }
 
 
 }

pro-base/src/main/java/com/idea/kafka/KafkaProducer.java

@@ -8,29 +8,29 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.stereotype.Component;
 
-@Component
-@AllArgsConstructor
+//@Component
+//@AllArgsConstructor
 public class KafkaProducer {
 
-    private static final Logger log = LoggerFactory.getLogger(KafkaProducer.class);
-
-    @Autowired
-    private KafkaTemplate<String, String> kafkaTemplate;
-
-    public void sendData(String data){
-
-        try {
-            for (int i = 0; i < 10; i++)
-            {
-                kafkaTemplate.send("test", "这是测试的数据==> "+data+" i ="+i );
-                Thread.sleep(1000);
-            }
-
-        }catch (Exception e){
-            e.printStackTrace();
-            log.error("出错！！！！！！！！！！！");
-        }
-
-    }
+//    private static final Logger log = LoggerFactory.getLogger(KafkaProducer.class);
+//
+//    @Autowired
+//    private KafkaTemplate<String, String> kafkaTemplate;
+//
+//    public void sendData(String data){
+//
+//        try {
+//            for (int i = 0; i < 10; i++)
+//            {
+//                kafkaTemplate.send("test", "这是测试的数据==> "+data+" i ="+i );
+//                Thread.sleep(1000);
+//            }
+//
+//        }catch (Exception e){
+//            e.printStackTrace();
+//            log.error("出错！！！！！！！！！！！");
+//        }
+//
+//    }
 
 }