与kafka SASL_PLAINTEXT的Apache Nifi连接问题

Question

我正在使用Kafka 2.0.0版。我已经在Kafka中启用了SASL_PLAINTEXT，并已通过控制台生产者和控制台使用者进行了测试，并且对我有用。现在，我尝试使用消耗卡夫卡发布和使用Nifi中的数据，并发布我无法建立连接的卡夫卡处理器。我遇到错误。

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客户端的已知配置机制。

Answer 1

我使用了Nifi的其他发布和消费处理器，然后为我工作了