From c67b51f77fb9f9fbe337e52bb62f8446e4fdf04b Mon Sep 17 00:00:00 2001 From: wanggeng <450292408@qq.com> Date: Mon, 27 Dec 2021 17:15:58 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84kafka=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=90=8C=E6=AD=A5=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/com/tenlion/usercenter/kafka/KafKaPublishConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 c7d3af4..6df8b11 100644 --- a/src/main/java/cn/com/tenlion/usercenter/kafka/KafKaPublishConsumer.java +++ b/src/main/java/cn/com/tenlion/usercenter/kafka/KafKaPublishConsumer.java @@ -133,7 +133,7 @@ public class KafKaPublishConsumer implements ApplicationEventPublisherAware { } } - @KafkaListener(id="C0022", topics = "C0022") + @KafkaListener(id="C0023", topics = "C0023") public void mapGridPoint(ConsumerRecord record) { String recordValue = record.value().toString(); LOG.debug("Grid Point(C0023) recordValue: {}", recordValue);