From 248b9bb4afc83d8110b57c82dabba544be2a44a4 Mon Sep 17 00:00:00 2001
From: Renpc-kilig <308442850@qq.com>
Date: Wed, 9 Feb 2022 17:30:05 +0800
Subject: [PATCH] =?UTF-8?q?bug=E4=BF=AE=E6=94=B9=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/tenlion/systemtask/utils/fullsync/FullSyncC0006.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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