Kafka Java 客户端：ClassLoader 找不到 SASL/Scram 登录类

Question

构建一个SPI以将事件推送到Kafka中，以在Keycloak 6.0.1中部署为EAR，它使用WildFly Server，打包在基于.jboss/keycloak:6.0.1

我遇到了：Kafka Producer - org.apache.kafka.common.serialization.StringSerializer 找不到

所以我应用了建议的设置解决方案Thread.currentThread().setContextClassLoader(null);。

这似乎适用于我在端口 9092 上的本地 Kafka，无需身份验证。一旦我按照此处所述进行身份验证：

String jaasTemplate = "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"%s\" password=\"%s\";";

String jaasCfg = String.format(jaasTemplate, username, password);

Properties props = new Properties();

props.put("sasl.jaas.config", jaasCfg);

// ...

Thread.currentThread().setContextClassLoader(null);

KafkaProducer<String, String> producer = new KafkaProducer<>(props);

我遇到了错误：

org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: unable to find LoginModule class: org.apache.kafka.common.security.scram.ScramLoginModule

    at org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:160)

    at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:146)

    at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:67)

    at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:99)

    at org.apache.kafka.clients.producer.KafkaProducer.newSender(KafkaProducer.java:441)

    at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:422)

我怀疑这是由于将 ClassLoader 设置为 引起的null，但我不确定。

JAAS 字符串提到了这个org.apache.kafka.common.security.scram.ScramLoginModule。我尝试不使用 JAAS，而是使用简单的用户名 + 密码，如下所示：

Properties props = new Properties();

props.put("sasl.username", username);

props.put("sasl.password", password);

// ...

Thread.currentThread().setContextClassLoader(null);

KafkaProducer<String, String> producer = new KafkaProducer<>(props);

我怎样才能找到它org.apache.kafka.common.security.scram.ScramLoginModule？谢谢！

Answer 1

警告：丑陋的骇客！在创建 KafkaProducer 之前，设置如下所示的上下文类加载器：Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());