diff --git a/src/main/java/cn/com/tenlion/systemtask/utils/fullsync/FullSyncC0006.java b/src/main/java/cn/com/tenlion/systemtask/utils/fullsync/FullSyncC0006.java
index ceda767..b7a1be6 100644
--- a/src/main/java/cn/com/tenlion/systemtask/utils/fullsync/FullSyncC0006.java
+++ b/src/main/java/cn/com/tenlion/systemtask/utils/fullsync/FullSyncC0006.java
@@ -32,7 +32,7 @@ public class FullSyncC0006 implements ApplicationEventPublisherAware {
 
     public FullSyncC0006() {}
 
-    @KafkaListener(topics = "C0002FullSync")
+    @KafkaListener(topics = "C0006FullSync")
     public void message(ConsumerRecord<?, ?> record) {
         System.out.println("收到全量同步命令");
         JSONObject jsonObject = JSONObject.parseObject(record.value().toString());
@@ -60,7 +60,7 @@ public class FullSyncC0006 implements ApplicationEventPublisherAware {
         }
     }
 
-    @KafkaListener(topics = "C0002")
+    @KafkaListener(topics = "C0006")
     public void messageMsg(ConsumerRecord<?, ?> record) {
         JSONObject jsonObject = JSONObject.parseObject(record.value().toString());
         Map<String, Object> params = new HashMap<>();