Tenlion/wlcb-smart-city-usercenter
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改kafkaListenerId

Browse Source
This commit is contained in:
wanggeng 2021-12-27 16:57:47 +08:00
parent 8fcdfa6d87
commit ac6dbec859
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/cn/com/tenlion/usercenter/kafka/KafKaPublishConsumer.java
View File

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