Я использую Kafka версии 2.0.0. Я включил SASL_PLAINTEXT в Kafka и проверил от производителя консоли и потребителя консоли, и это работает для меня. Сейчас я пытаюсь опубликовать sh и использовать данные из Nifi с использованием процессоров потребления Kafka и publi sh 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.