采集事件增加id主键

b1089a65 · 魏建枢 · a94b3054 · b1089a65
Commit b1089a65 authored Dec 25, 2024 by 魏建枢
Showing with 1 additions and 0 deletions
flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorDataFormatUtil.java
--- a/flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorDataFormatUtil.java
+++ b/flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorDataFormatUtil.java
@@ -38,6 +38,7 @@ public class InterceptorDataFormatUtil {
 	
 	public static List<String> eventLogDataFormat(JSONObject jsonObj) {
 		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("id"));
 		arrayList.add(jsonObj.getString("send_time"));
 		arrayList.add(jsonObj.getString("create_time"));
 		arrayList.add(jsonObj.getString("strategy_group_id"));