From 8ce3007a8862a855bc9f92da76f6278f0863be4d Mon Sep 17 00:00:00 2001
From: duanledexianxianxian <fengyuchenglun@foxmail.com>
Date: Wed, 23 Oct 2019 17:52:57 +0800
Subject: [PATCH] sync

---
 .../demo/kafka/consumer/TestConsumer.java                     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/consumer/TestConsumer.java b/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/consumer/TestConsumer.java
index 8c92b45..0459282 100644
--- a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/consumer/TestConsumer.java
+++ b/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/consumer/TestConsumer.java
@@ -10,7 +10,7 @@ import org.springframework.stereotype.Component;
  * @author fengyuchenglun
  * @version 1.0.0
  */
-//@Component
+@Component
 public class TestConsumer {
 
     /**
@@ -19,7 +19,7 @@ public class TestConsumer {
      * @param record the record
      * @throws Exception the exception
      */
-    @KafkaListener(topics = "topic_first")
+    @KafkaListener(topics = "topic_second")
     public void listen(ConsumerRecord<?, ?> record) throws Exception {
         System.out.printf("topic = %s, offset = %d, value = %s \n", record.topic(), record.offset(), record.value());
     }
-- 
GitLab