Explorar o código

删除更新时间次序更新

xufei %!s(int64=4) %!d(string=hai) anos
pai
achega
74af06b990
Modificáronse 1 ficheiros con 3 adicións e 1 borrados
  1. 3 1
      src/main/java/com/winhc/task/PersonMergeIncremnetTask.java

+ 3 - 1
src/main/java/com/winhc/task/PersonMergeIncremnetTask.java

@@ -86,8 +86,10 @@ public class PersonMergeIncremnetTask {
 
     private void sendKafka(MergeParam param) throws InterruptedException, ExecutionException, TimeoutException {
         //加载文件发送kafka
-        loadCSVSendKafka(param.getPathPre(), param.getMergePath(), param.getTopic(), "0");
         loadCSVSendKafka(param.getPathPre(), param.getDeletedPath(), param.getTopic(), "1");
+        //保证先移除,再更新
+        Thread.sleep(10*1000);
+        loadCSVSendKafka(param.getPathPre(), param.getMergePath(), param.getTopic(), "0");
     }
 
     private void mergeAndExport(MergeParam param) {