fix

src/main/java/com/zm/order/tool/server/listener/reverse/ResConvertCommentSyncListener.java

@@ -58,7 +58,7 @@ public class ResConvertCommentSyncListener {
     @Value("${new.sharding.tb.size}")
     private int tbSize;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.order.comment.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.order.comment.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_comment_consumer]before！");

src/main/java/com/zm/order/tool/server/listener/reverse/ResConvertItemCommentSyncListener.java

@@ -59,7 +59,7 @@ public class ResConvertItemCommentSyncListener {
     @Value("${new.sharding.tb.size}")
     private int tbSize;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.item.comment.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.item.comment.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_item_comment_consumer]before！");

src/main/java/com/zm/order/tool/server/listener/reverse/ResConvertOrderSyncListener.java

@@ -79,7 +79,7 @@ public class ResConvertOrderSyncListener implements InitializingBean {
     private OrderEncryptionHandler orderEncryption;
 
     // 根据品牌id做数据双写过滤
-    @KafkaListener(topics = "${kafka.bin.log.sync.order.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.order.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             if (CollectionUtils.isEmpty(recordList)) {

src/main/java/com/zm/order/tool/server/listener/reverse/ResConvertPayDetailsSyncListener.java

@@ -58,7 +58,7 @@ public class ResConvertPayDetailsSyncListener {
     @Value("${new.sharding.tb.size}")
     private int tbSize;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.order.pay.details.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.order.pay.details.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_order_pay_details_consumer]before！");

src/main/java/com/zm/order/tool/server/listener/reverse/ResConvertRefundDetailSyncListener.java

@@ -50,7 +50,7 @@ public class ResConvertRefundDetailSyncListener {
     @Autowired
     private NewDataSourceOrderDao orderDao;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.refund.details.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.refund.details.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_refund_details_consumer]before！");

src/main/java/com/zm/order/tool/server/listener/reverse/ResConvertRefundSyncListener.java

@@ -61,7 +61,7 @@ public class ResConvertRefundSyncListener implements InitializingBean {
     @Autowired
     private RefundEncryptionHandler encryptionHandler;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.order.refunds.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.order.refunds.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_res_refund_consumer]before！");

src/main/java/com/zm/order/tool/server/listener/standard/ConvertCommentSyncListener.java

@@ -58,7 +58,7 @@ public class ConvertCommentSyncListener {
     @Value("${new.sharding.tb.size}")
     private int tbSize;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.new.order.comment.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.new.order.comment.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_comment_consumer]before！");

src/main/java/com/zm/order/tool/server/listener/standard/ConvertItemCommentSyncListener.java

@@ -59,7 +59,7 @@ public class ConvertItemCommentSyncListener {
     @Value("${new.sharding.tb.size}")
     private int tbSize;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.new.item.comment.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.new.item.comment.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_item_comment_consumer]before！");

src/main/java/com/zm/order/tool/server/listener/standard/ConvertOrderSyncListener.java

@@ -79,7 +79,7 @@ public class ConvertOrderSyncListener implements InitializingBean {
     private OrderEncryptionHandler orderEncryption;
 
     // 根据品牌id做数据双写过滤
-    @KafkaListener(topics = "${kafka.bin.log.sync.new.order.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.new.order.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             if (CollectionUtils.isEmpty(recordList)) {

src/main/java/com/zm/order/tool/server/listener/standard/ConvertPayDetailsSyncListener.java

@@ -62,7 +62,7 @@ public class ConvertPayDetailsSyncListener {
     @Value("${new.sharding.tb.size}")
     private int tbSize;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.new.order.pay.details.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.new.order.pay.details.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_order_pay_details_consumer]before！");

src/main/java/com/zm/order/tool/server/listener/standard/ConvertRefundDetailSyncListener.java

@@ -50,7 +50,7 @@ public class ConvertRefundDetailSyncListener {
     @Autowired
     private OrderDao orderDao;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.new.refund.details.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.new.refund.details.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_refund_details_consumer]before！");

src/main/java/com/zm/order/tool/server/listener/standard/ConvertRefundSyncListener.java

@@ -67,7 +67,7 @@ public class ConvertRefundSyncListener implements InitializingBean {
 
     private ExecutorService executorService;
 
-    @KafkaListener(topics = "${kafka.bin.log.sync.new.order.refunds.topic}")
+//    @KafkaListener(topics = "${kafka.bin.log.sync.new.order.refunds.topic}")
     public void consumer(List<ConsumerRecord<String, String>> recordList, Acknowledgment ack) {
         try {
             logger.info("[bin_log_sync_refund_consumer]before！");