(inlong) branch master updated: [INLONG-11826][Audit] Add a new Audit item for MQ Pulsar (#11827)

[dockerzhang]

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

dockerzhang 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 829a4d0842 [INLONG-11826][Audit] Add a new Audit item for MQ Pulsar 
(#11827)
829a4d0842 is described below

commit 829a4d08425694dcdadbd4a47604fdf6768cab57
Author: doleyzi <43397300+dole...@users.noreply.github.com>
AuthorDate: Wed Apr 16 09:57:27 2025 +0800

    [INLONG-11826][Audit] Add a new Audit item for MQ Pulsar (#11827)
---
 .../src/main/java/org/apache/inlong/audit/AuditIdEnum.java | 14 +++++++++++++-
 .../java/org/apache/inlong/audit/entity/AuditType.java     |  4 +++-
 2 files changed, 16 insertions(+), 2 deletions(-)

diff --git 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java
index 8186e98181..39f3276bbd 100644
--- 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java
+++ 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java
@@ -26,6 +26,7 @@ import org.slf4j.LoggerFactory;
 
 import static org.apache.inlong.audit.entity.AuditType.AGENT;
 import static org.apache.inlong.audit.entity.AuditType.BINLOG;
+import static org.apache.inlong.audit.entity.AuditType.BSS;
 import static org.apache.inlong.audit.entity.AuditType.CLICKHOUSE;
 import static org.apache.inlong.audit.entity.AuditType.DATAPROXY;
 import static org.apache.inlong.audit.entity.AuditType.DORIS;
@@ -35,11 +36,13 @@ import static org.apache.inlong.audit.entity.AuditType.HDFS;
 import static org.apache.inlong.audit.entity.AuditType.HIVE;
 import static org.apache.inlong.audit.entity.AuditType.HUDI;
 import static org.apache.inlong.audit.entity.AuditType.ICEBERG;
+import static org.apache.inlong.audit.entity.AuditType.ICEBERG_AO;
 import static org.apache.inlong.audit.entity.AuditType.KUDU;
 import static org.apache.inlong.audit.entity.AuditType.MYSQL;
 import static org.apache.inlong.audit.entity.AuditType.POSTGRES;
 import static org.apache.inlong.audit.entity.AuditType.SDK;
 import static org.apache.inlong.audit.entity.AuditType.STARROCKS;
+import static org.apache.inlong.audit.entity.AuditType.TDSQL_MYSQL;
 import static org.apache.inlong.audit.entity.AuditType.TUBEMQ;
 import static org.apache.inlong.audit.entity.FlowType.INPUT;
 import static org.apache.inlong.audit.entity.FlowType.OUTPUT;
@@ -98,7 +101,16 @@ public enum AuditIdEnum {
     SORT_MYSQL_OUTPUT(36, OUTPUT, MYSQL, "Sent Audit Metrics for Sort MySQL"),
 
     SORT_HDFS_INPUT(37, INPUT, HDFS, "Received Audit Metrics for Sort HDFS"),
-    SORT_HDFS_OUTPUT(38, OUTPUT, HDFS, "Sent Audit Metrics for Sort HDFS");
+    SORT_HDFS_OUTPUT(38, OUTPUT, HDFS, "Sent Audit Metrics for Sort HDFS"),
+
+    SORT_TDSQL_MYSQL_INPUT(39, INPUT, TDSQL_MYSQL, "Received Audit Metrics for 
TDSQL MYSQL"),
+    SORT_TDSQL_MYSQL_OUTPUT(40, OUTPUT, TDSQL_MYSQL, "Sent Audit Metrics for 
TDSQL MYSQL"),
+
+    BSS_INPUT(41, INPUT, BSS, "Received Audit Metrics for BSS"),
+    BSS_OUTPUT(42, OUTPUT, BSS, "Sent Audit Metrics for BSS"),
+
+    ICEBERG_AO_INPUT(43, INPUT, ICEBERG_AO, "Received Audit Metrics for 
ICEBERG AO"),
+    ICEBERG_AO_OUTPUT(44, OUTPUT, ICEBERG_AO, "Sent Audit Metrics for ICEBERG 
AO");
 
     private static final Logger LOGGER = 
LoggerFactory.getLogger(AuditIdEnum.class);
     private final int auditId;
diff --git 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java
 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java
index 735a6fdc09..e2a359bf27 100644
--- 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java
+++ 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java
@@ -36,7 +36,9 @@ public enum AuditType {
     TUBEMQ("TubeMQ"),
     MYSQL("MYSQL"),
     HDFS("HDFS"),
-    TDSQL_MYSQL("TDSQL_MYSQL");
+    TDSQL_MYSQL("TDSQL_MYSQL"),
+    BSS("BSS"),
+    ICEBERG_AO("ICEBERG_AO");
 
     private final String auditType;