融合通信对接合肥数据

2026-03-19 11:35:54 +08:00 · 2026-03-19 11:35:54 +08:00 · d9396f33d1
parent 20c066890e
commit d9396f33d1
1 changed files with 1 additions and 1 deletions
--- a/stwzhj-modules/wzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java
+++ b/stwzhj-modules/wzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java
@ -51,7 +51,7 @@ public class ConsumerWorker {
    private RemoteDataToEsService gpsService;


-    @KafkaListener(topics = "${spring.kafka.consumer.topics}",properties = {
+    @KafkaListener(topics = "#{'${spring.kafka.consumer.topics}'.split(',')}",properties = {
        "auto.offset.reset:latest"})
    public void consumer(ConsumerRecord<String,Object> record) {
        Object value = record.value();