From ea0390e454f75eee4abe600921d33258cb40056f Mon Sep 17 00:00:00 2001
From: Ax1an <ax1an@foxmail.com>
Date: Wed, 28 Apr 2021 07:45:42 +0800
Subject: [PATCH] Enhance reconnection mechanism of agent kafka reporter
 plugin. (#6855)

---
 .../skywalking/apm/agent/core/kafka/KafkaProducerManager.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaProducerManager.java b/apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaProducerManager.java
index efa1e138bf..f9bccc56ec 100644
--- a/apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaProducerManager.java
+++ b/apm-sniffer/optional-reporter-plugins/kafka-reporter-plugin/src/main/java/org/apache/skywalking/apm/agent/core/kafka/KafkaProducerManager.java
@@ -127,6 +127,7 @@ public class KafkaProducerManager implements BootService, Runnable {
             producer = new KafkaProducer<>(properties, new StringSerializer(), new BytesSerializer());
         } catch (Exception e) {
             LOGGER.error(e, "connect to kafka cluster '{}' failed", KafkaReporterPluginConfig.Plugin.Kafka.BOOTSTRAP_SERVERS);
+            return;
         }
         //notify listeners to send data if no exception been throw
         notifyListeners(KafkaConnectionStatus.CONNECTED);
-- 
GitLab