no message

.drone.yml

@@ -80,7 +80,7 @@ steps:
         - echo ====开始部署=======
         - cd /home/ABServer/
         - cp -r /home/ABServer/deploy-ready/kxs-gateway /home/ABServer/webroot/
-        - docker stop kxs-gateway && docker rm kxs-gateway && docker-compose up -d
+        - docker stop kxs-gateway && docker rm kxs-gateway && docker-compose up -d kxs-gateway
         # - docker restart nodeServer1
         - echo ====部署成功=======
 
@@ -176,7 +176,7 @@ steps:
         - echo ====开始部署=======
         - cd /home/ABServer/
         - cp -r /home/ABServer/deploy-ready/kxs-transfer /home/ABServer/webroot/
-        - docker stop kxs-transfer && docker rm kxs-transfer && docker-compose up -d
+        - docker stop kxs-transfer && docker rm kxs-transfer && docker-compose up -d kxs-transfer
         # - docker restart nodeServer1
         - echo ====部署成功=======
 

kxs-transfer/src/main/java/com/kxs/transfer/api/controller/DtsController.java

@@ -68,6 +68,8 @@ public class DtsController {
             record.commit(String.valueOf(record.getSourceTimestamp()));
             return;
         }
+        log.info("开始消费:{}表的数据，dataID:{}", dmlData.getTableName(), dataId);
+
         //用户表
         if("Users".equals(dmlData.getTableName())){
             kxsUserService.changeUser(dmlData);
@@ -96,7 +98,6 @@ public class DtsController {
         kxsDtsLog.setTableName(dmlData.getTableName());
         kxsDtsLog.setOperation(dmlData.getOperation().toString());
         kxsDtsLogService.save(kxsDtsLog);
-        log.info("消费dts的数据表信息:{}", dmlData.getValidFieldDataMap());
 
         record.commit(String.valueOf(record.getSourceTimestamp()));
     }