Apache Nifi 与 kafka SASL_PLAINTEXT 的连接问题答案

【问题标题】：Apache Nifi connection issue with kafka SASL_PLAINTEXTApache Nifi 与 kafka SASL_PLAINTEXT 的连接问题
【发布时间】：2020-06-07 19:09:22
【问题描述】：

我使用的是 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 使用的属性

安全协议 = SASL_PLAINTEXT

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

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

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

【问题讨论】：

标签： java apache-kafka apache-nifi jaas

【解决方案1】：

我使用了来自 Nifi 的不同发布和消费处理器然后它对我有用

【讨论】：

我也面临同样的问题。请你帮助我好吗。您能告诉我您使用的 iprocessor 版本吗？