(inlong) branch master updated: [INLONG-9993][Audit] The data protocol adds an audit_version attribute (#9994)

[wenweihuang]

This is an automated email from the ASF dual-hosted git repository.

wenweihuang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new d6c523c256 [INLONG-9993][Audit] The data protocol adds an 
audit_version attribute (#9994)
d6c523c256 is described below

commit d6c523c256fae973aa7f9b849a7fbca8c3807c9b
Author: doleyzi <43397300+dole...@users.noreply.github.com>
AuthorDate: Tue Apr 16 14:05:02 2024 +0800

    [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
---
 .../src/main/java/org/apache/inlong/common/constant/Constants.java   | 3 +++
 .../main/java/org/apache/inlong/common/msg/AttributeConstants.java   | 5 ++++-
 2 files changed, 7 insertions(+), 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
index 3aaee8238a..766e3c4a44 100644
--- 
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
index 43922ee065..ceaeef3054 100644
--- 
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";
 }