sxtt

src/main/java/com/cxzx/sxtt/SyncMain.java

@@ -51,6 +51,7 @@ public class SyncMain {
                     if (null == record.value()){
                         continue;
                     }
+                    count++;
                     TreeMap<String, Object> treeMap = om.readValue(record.value(), TreeMap.class);
 
                     if("author_843ea558d5ef41a1877584c62762632d_app".equals(record.topic()) || "article_843ea558d5ef41a1877584c62762632d_app".equals(record.topic())){
@@ -59,7 +60,6 @@ public class SyncMain {
                             continue;
                         }
                     }
-                    count++;
 
                     log.info("读取数据 topic:{}, offset: {}, data: {}, 时间: {}", record.topic(),record.offset(),record.value(), record.timestamp());