[INLONG-9993][Audit] The data protocol adds an audit_version attribute (

#9994) * The data protocol adds an audit_version attribute * The data protocol adds an audit_version attribute * The data protocol adds an audit_version attribute
apache · Apr 16, 2024 · d6c523c · d6c523c
1 parent 967a21a
commit d6c523c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/inlong-common/src/main/java/org/apache/inlong/common/constant/Constants.java b/inlong-common/src/main/java/org/apache/inlong/common/constant/Constants.java
@@ -30,4 +30,7 @@ public class Constants {
     public static final String DEFAULT_KAFKA_TOPIC_FORMAT = "%s.%s";
     public static final String METRICS_AUDIT_PROXY_HOSTS_KEY = "metrics.audit.proxy.hosts";
 
+    // Default audit version is -1
+    public static final long DEFAULT_AUDIT_VERSION = -1;
+
 }
diff --git a/inlong-common/src/main/java/org/apache/inlong/common/msg/AttributeConstants.java b/inlong-common/src/main/java/org/apache/inlong/common/msg/AttributeConstants.java
@@ -103,5 +103,8 @@ public interface AttributeConstants {
     // the downstream by the Bus without modification for the downstream to
     // calculate the end-to-end message delay; if this field does not exist in the request,
     // it will be added by the Bus with the current time
-    public static final String MSG_RPT_TIME = "rtms";
+    String MSG_RPT_TIME = "rtms";
+
+    // Audit version is used for audit to reconciliation
+    String AUDIT_VERSION = "auditVersion";
 }