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

Question

构建一个SPI将事件推送到Kafka中，在Keycount 6.0.1中部署为EAR，它使用WildFly Server，打包在基于jboss/keycount:6.0.1的Docker映像中。

我碰到了:找不到Kafka Producer-org . Apache . Kafka . common . serialize . string serializer

因此，我应用了设置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)

我怀疑这是由于将类加载器设置为空引起的，但我不确定。

JAAS字符串提到这个org.apache.kafka.common.security.scraf.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.KafkaException: javax.security.auth.login.LoginException: unable to find LoginModule class: org.jboss.as.security.remoting.RemotingLoginModule
    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)

我如何才能做到，org.apache.kafka.common.security.scrab。是否找到ScramLoginModule？谢谢




Answer 1

警告：丑陋的黑客！

在创建KafkaProducer之前，设置如下所示的上下文类加载器:

Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());