sxtt

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

@@ -32,8 +32,7 @@ public class SyncMain {
 
     public static void main(String[] args) {
         AliyunLogger aliyunLogger = new AliyunLogger("java-log");
-        LogItem logItem = new LogItem();
-        logItem.PushBack("app", "sxtt-sync");
+
         KafkaConsumer<String, String> consumer = new KafkaConsumer<>(KafkaConfig.getSXTTKafkaConsumerProperties());
         ObjectMapper om = new ObjectMapper();
         om.setConfig(om.getSerializationConfig()
@@ -56,6 +55,9 @@ public class SyncMain {
                         continue;
                     }
                     count++;
+                    LogItem logItem = new LogItem();
+                    logItem.PushBack("app", "sxtt-sync");
+
                     TreeMap<String, Object> treeMap = om.readValue(record.value(), TreeMap.class);
 
                     if("author_843ea558d5ef41a1877584c62762632d_app".equals(record.topic()) || "article_843ea558d5ef41a1877584c62762632d_app".equals(record.topic())){
@@ -100,6 +102,8 @@ public class SyncMain {
             }
         }catch (Exception e){
             log.error(e.getMessage(), e);
+            LogItem logItem = new LogItem();
+            logItem.PushBack("app", "sxtt-sync");
             logItem.PushBack( "error", e.getMessage());
             aliyunLogger.error(logItem);
         }