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);