java - Apache Nifi 与 kafka SASL_PLAINTEXT 的连接问题

Question

我使用的是 Kafka 2.0.0 版本。我已经在 Kafka 中启用了 SASL_PLAINTEXT 并从控制台生产者和控制台消费者进行了测试，它对我有用。现在我尝试使用消费 Kafka 发布和使用来自 Nifi 的数据并发布 Kafka 处理器，但我无法进行连接。我遇到以下错误。

Caused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: unable to find LoginModule class: org.apache.kafka.common.security.plain.PlainLoginModule

Caused by: javax.security.auth.login.LoginException: unable to find LoginModule class: org.apache.kafka.common.security.plain.PlainLoginModule

下面是我在 Nifi 端所做的配置。

我将kafka_client_jaas.conf文件保存在Nifi配置路径(/opt/nifi/nifi-1.9.2/conf/)

以下是我从 Nifi 使用的属性

安全协议(protocol) = SASL_PLAINTEXT

我正在尝试添加以下属性，但没有获得连接。

sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required

SASL 机制无效，因为必须是该 Kafka 客户端的已知配置机制。

Answer 1

我使用了 Nifi 的不同发布和消费处理器，那么它对我有用