(inlong) branch master updated: [INLONG-11396][Audit] Add monitoring of pulsar producer creation failure for Audit Proxy (#11399)

[aloyszhang]

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

aloyszhang 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 d50ed3b36f [INLONG-11396][Audit] Add monitoring of pulsar producer 
creation failure for Audit Proxy (#11399)
d50ed3b36f is described below

commit d50ed3b36f4b1d9b2067b9b454e1b779358eb009
Author: doleyzi <43397300+dole...@users.noreply.github.com>
AuthorDate: Wed Oct 23 18:32:00 2024 +0800

    [INLONG-11396][Audit] Add monitoring of pulsar producer creation failure 
for Audit Proxy (#11399)
---
 .../java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java
 
b/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java
index c35617a27b..2995fa12fc 100644
--- 
a/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java
+++ 
b/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java
@@ -19,6 +19,7 @@ package org.apache.inlong.audit.sink.pulsar;
 
 import org.apache.inlong.audit.consts.AttributeConstants;
 import org.apache.inlong.audit.file.ConfigManager;
+import org.apache.inlong.audit.metric.MetricsManager;
 import org.apache.inlong.audit.sink.EventStat;
 import org.apache.inlong.audit.utils.LogCounter;
 import org.apache.inlong.common.constant.MQType;
@@ -160,6 +161,7 @@ public class PulsarClientService {
 
         if (producer == null) {
             logger.error("Get producer is null!");
+            MetricsManager.getInstance().addSendFailed(1);
             return false;
         }