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