From d9396f33d18b5a9576dca015ba72bcc2557ff33f Mon Sep 17 00:00:00 2001
From: luyya <luya0519>
Date: Thu, 19 Mar 2026 11:35:54 +0800
Subject: [PATCH] =?UTF-8?q?=E8=9E=8D=E5=90=88=E9=80=9A=E4=BF=A1=E5=AF=B9?=
 =?UTF-8?q?=E6=8E=A5=E5=90=88=E8=82=A5=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/org/dromara/kafka/consumer/handler/ConsumerWorker.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 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
index 980d0312..e1a2332e 100644
--- 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();