与kafka SASL_PLAINTEXT的Apache Nifi连接问题
来源：爱站网时间：2021-09-17编辑：网友分享
我正在使用Kafka 2.0.0版。我已经在Kafka中启用了SASL_PLAINTEXT，并已通过控制台生产者和控制台使用者进行了测试，并且对我有用。现在，我正在尝试发布和使用数据...
问题描述
我正在使用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客户端的已知配置机制。
思路：
我使用了Nifi的其他发布和消费处理器，然后为我工作了
