From 8fcdfa6d8734068cb3f9be1a91326d1811fa714f Mon Sep 17 00:00:00 2001 From: wanggeng <450292408@qq.com> Date: Mon, 27 Dec 2021 16:09:45 +0800 Subject: [PATCH] =?UTF-8?q?kafka=E6=B6=88=E8=B4=B9=E8=80=85=E6=B7=BB?= =?UTF-8?q?=E5=8A=A0=E7=9B=91=E5=90=ACID?= 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 456acf1..e237fe4 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(topics = {"C0021"}) + @KafkaListener(id="UserCenter1", 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(topics = {"C0022"}) + @KafkaListener(id="UserCenter1", 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(topics = {"C0023"}) + @KafkaListener(id="UserCenter1", topics = "C0023") public void mapGridPoint(ConsumerRecord record) { String recordValue = record.value().toString(); LOG.debug("Grid Point(C0023) recordValue: {}", recordValue);