From 6228d450e1b0792dd9875ad68984c89c81ece742 Mon Sep 17 00:00:00 2001 From: Elliot Duan Date: Sun, 11 Jul 2021 22:39:51 +0800 Subject: [PATCH] support Kafka SASL login module. (#7281) Co-authored-by: Elliot Duan --- CHANGES.md | 1 + .../skywalking/apm/agent/core/kafka/KafkaProducerManager.java | 3 +++ 2 files changed, 4 insertions(+) diff --git a/CHANGES.md b/CHANGES.md index be7e433a6..9c9dbaeca 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -31,6 +31,7 @@ Release Notes. * Move `ehcache-2.x` plugin as an optional plugin. * Support `guava-cache` plugin. * Enhance the compatibility of `mysql-8.x-plugin` plugin. +* Support Kafka SASL login module. #### OAP-Backend 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 695b51d4e..a3c52bb25 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 @@ -44,6 +44,7 @@ import org.apache.skywalking.apm.agent.core.boot.DefaultNamedThreadFactory; import org.apache.skywalking.apm.agent.core.boot.ServiceManager; import org.apache.skywalking.apm.agent.core.logging.api.ILog; import org.apache.skywalking.apm.agent.core.logging.api.LogManager; +import org.apache.skywalking.apm.agent.core.plugin.loader.AgentClassLoader; import org.apache.skywalking.apm.agent.core.remote.GRPCChannelManager; import org.apache.skywalking.apm.util.RunnableWithExceptionProtection; import org.apache.skywalking.apm.util.StringUtil; @@ -96,6 +97,8 @@ public class KafkaProducerManager implements BootService, Runnable { @Override public void run() { + Thread.currentThread().setContextClassLoader(AgentClassLoader.getDefault()); + Properties properties = new Properties(); properties.setProperty( ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, KafkaReporterPluginConfig.Plugin.Kafka.BOOTSTRAP_SERVERS);