完善kafka数据同步消息

2021-12-27 17:15:58 +08:00 · 2021-12-27 17:15:58 +08:00 · c67b51f77f
commit c67b51f77f
parent ac6dbec859
1 changed files with 1 additions and 1 deletions
--- 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);