From ac6dbec859107264283cb636818ae721aac24607 Mon Sep 17 00:00:00 2001
From: wanggeng <450292408@qq.com>
Date: Mon, 27 Dec 2021 16:57:47 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9kafkaListenerId?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/tenlion/usercenter/kafka/KafKaPublishConsumer.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/cn/com/tenlion/usercenter/kafka/KafKaPublishConsumer.java b/src/main/java/cn/com/tenlion/usercenter/kafka/KafKaPublishConsumer.java
index e237fe4..c7d3af4 100644
--- a/src/main/java/cn/com/tenlion/usercenter/kafka/KafKaPublishConsumer.java
+++ b/src/main/java/cn/com/tenlion/usercenter/kafka/KafKaPublishConsumer.java
@@ -64,7 +64,7 @@ public class KafKaPublishConsumer implements ApplicationEventPublisherAware {
     public KafKaPublishConsumer() {
     }
 
-    @KafkaListener(id="UserCenter1", topics = "C0021")
+    @KafkaListener(id="C0021", topics = "C0021")
     public void gridRelation(ConsumerRecord<?, ?> record) {
         String recordValue = record.value().toString();
         LOG.debug("Grid Relation(C0021) recordValue: {}", recordValue);
@@ -94,7 +94,7 @@ public class KafKaPublishConsumer implements ApplicationEventPublisherAware {
         }
     }
 
-    @KafkaListener(id="UserCenter1", topics = "C0022")
+    @KafkaListener(id="C0022", topics = "C0022")
     public void mapGrid(ConsumerRecord<?, ?> record) {
         String recordValue = record.value().toString();
         LOG.debug("Grid(C0022) recordValue: {}", recordValue);
@@ -133,7 +133,7 @@ public class KafKaPublishConsumer implements ApplicationEventPublisherAware {
         }
     }
 
-    @KafkaListener(id="UserCenter1", topics = "C0023")
+    @KafkaListener(id="C0022", topics = "C0022")
     public void mapGridPoint(ConsumerRecord<?, ?> record) {
         String recordValue = record.value().toString();
         LOG.debug("Grid Point(C0023) recordValue: {}", recordValue);