feature: topic恢复

ruoyi-server/ruoyi-server-mqdata/src/main/java/org/dromara/server/mq/consumer/KafkaCloudConsumer.java

@@ -35,9 +35,8 @@ public class KafkaCloudConsumer {
      *
      * @param record 消息记录
      */
-    //@KafkaListener(topics = KafkaTopicConstants.OLD_SYNC_TOPIC, groupId = "old-to-cloud-group")
-    @KafkaListener(topics = "eventBus_test", groupId = "old-to-cloud-group1")
-
+    @KafkaListener(topics = KafkaTopicConstants.OLD_SYNC_TOPIC, groupId = "old-to-cloud-group")
+    //@KafkaListener(topics = "eventBus_test", groupId = "old-to-cloud-group1")
     public void kafkaEventBusHandler(ConsumerRecord<String, String> record) {
         KafkaMessage<?> receiveMsg = JSONUtil.toBean(record.value(), KafkaMessage.class);
         String sender = receiveMsg.getHeader().getSender();