[INLONG-11396][Audit] Add monitoring of pulsar producer creation fail…

…ure for Audit Proxy (#11399)
apache · Oct 23, 2024 · d50ed3b · d50ed3b
1 parent 1bdc9e2
commit d50ed3b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...it/audit-proxy/src/main/java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java b/...it/audit-proxy/src/main/java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java
@@ -19,6 +19,7 @@
 
 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 boolean sendMessage(String topic, Event event,
 
         if (producer == null) {
             logger.error("Get producer is null!");
+            MetricsManager.getInstance().addSendFailed(1);
             return false;
         }