diff --git a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/AgentConstants.java b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/AgentConstants.java index ec5831973be..f7c0f0d7c8b 100755 --- a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/AgentConstants.java +++ b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/AgentConstants.java @@ -68,6 +68,7 @@ public class AgentConstants { public static final String AUDIT_ENABLE = "audit.enable"; public static final boolean DEFAULT_AUDIT_ENABLE = true; + public static final String AUDIT_PROXY_ADDRESS = "audit.proxys"; public static final String AGENT_HISTORY_PATH = "agent.history.path"; public static final String DEFAULT_AGENT_HISTORY_PATH = ".history"; diff --git a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/audit/AuditUtils.java b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/audit/AuditUtils.java index fa425d7782b..b4f74bfc63c 100644 --- a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/audit/AuditUtils.java +++ b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/audit/AuditUtils.java @@ -22,7 +22,10 @@ import org.apache.inlong.audit.AuditOperator; import org.apache.inlong.audit.entity.AuditComponent; +import java.util.HashSet; + import static org.apache.inlong.agent.constant.AgentConstants.AUDIT_ENABLE; +import static org.apache.inlong.agent.constant.AgentConstants.AUDIT_PROXY_ADDRESS; import static org.apache.inlong.agent.constant.AgentConstants.DEFAULT_AUDIT_ENABLE; import static org.apache.inlong.agent.constant.FetcherConstants.AGENT_MANAGER_ADDR; import static org.apache.inlong.agent.constant.FetcherConstants.AGENT_MANAGER_AUTH_SECRET_ID; @@ -67,8 +70,14 @@ public class AuditUtils { public static void initAudit(AbstractConfiguration conf) { IS_AUDIT = conf.getBoolean(AUDIT_ENABLE, DEFAULT_AUDIT_ENABLE); if (IS_AUDIT) { - AuditOperator.getInstance().setAuditProxy(AuditComponent.AGENT, conf.get(AGENT_MANAGER_ADDR), - conf.get(AGENT_MANAGER_AUTH_SECRET_ID), conf.get(AGENT_MANAGER_AUTH_SECRET_KEY)); + if (conf.hasKey(AUDIT_PROXY_ADDRESS)) { + HashSet address = new HashSet<>(); + address.add(conf.get(AUDIT_PROXY_ADDRESS)); + AuditOperator.getInstance().setAuditProxy(address); + } else { + AuditOperator.getInstance().setAuditProxy(AuditComponent.AGENT, conf.get(AGENT_MANAGER_ADDR), + conf.get(AGENT_MANAGER_AUTH_SECRET_ID), conf.get(AGENT_MANAGER_AUTH_SECRET_KEY)); + } AuditOperator.getInstance().setLocalIP(conf.get(AgentConstants.AGENT_LOCAL_IP)); } } diff --git a/inlong-agent/conf/agent.properties b/inlong-agent/conf/agent.properties index ec5637eb086..11520057240 100755 --- a/inlong-agent/conf/agent.properties +++ b/inlong-agent/conf/agent.properties @@ -98,3 +98,7 @@ agent.prometheus.exporter.port=9080 ############################ # whether to enable audit audit.enable=true +# Audit proxy address +# By default, the audit address is obtained from the manager, and only in special circumstances do +# special addresses need to be specified through this configuration option +# audit.proxys= \ No newline at end of file