Кафка «Модуль входа не указан в конфигурации JAAS» ⇐ JAVA

[Anonymous]

У меня возникла проблема при общении с Kafka, защищенным с помощью sasl, с использованием консольных сценариев. Kafka защищен с помощью sasl, прослушиватель — SASL_PLAINTEXT, а механизм — PLAIN.

Что я сделал:
Я попробовал вывести некоторые данные с помощью одного из скриптов Кафки:

Код: Выделить всё

bin/kafka-consumer-groups.sh --bootstrap-server (address) --list

Как я понимаю

Код: Выделить всё

WARN Bootstrap broker (address) disconnected (org.apache.kafka.clients.NetworkClient)

и команда завершается с ошибкой, что вполне понятно, поскольку она защищена с помощью sasl.

Поэтому я попробовал добавить клиента имя пользователя/пароль для этой команды.
Сначала я попытался запустить скрипт kafka-console-consumer, я использовал --command-config, чтобы добавить необходимый файл. Я быстро обнаружил, что не могу добавить файл jaas напрямую, и мне нужно было использовать файл .properties, что я и сделал.

Мои свойства файл(имейте в виду, что в скобках указаны "цензурированные" данные, я не могу разместить здесь все реальные данные):

Код: Выделить всё

bootstrap.servers=(address)
zookeeper.connect=127.0.0.1:2181
zookeeper.connection.timeout.ms=6000
sasl.jaas.config=(path)/consumer_jaas.conf
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
group.id=(group)

Мой файл jaas:

Код: Выделить всё

KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username=(username)
password=(password);
};

Этот файл jaas работает в моих стандартных Java-приложениях.

Однако, когда я пытаясь запустить скрипт kafka-consumer-groups или kafka-console-consumer, я получаю эту ошибку:

Код: Выделить всё

Exception in thread "main" org.apache.kafka.common.KafkaException: java.lang.IllegalArgumentException: Login module not specified in JAAS config
at org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:94)
at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:93)
at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:51)
at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:84)
at kafka.admin.AdminClient$.create(AdminClient.scala:229)
at kafka.admin.AdminClient$.create(AdminClient.scala:223)
at kafka.admin.AdminClient$.create(AdminClient.scala:221)
at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.createAdminClient(ConsumerGroupCommand.scala:454)
at kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.(ConsumerGroupCommand.scala:389)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:65)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
Caused by: java.lang.IllegalArgumentException: Login module not specified in JAAS config
at org.apache.kafka.common.security.JaasConfig.(JaasConfig.java:68)
at org.apache.kafka.common.security.JaasUtils.jaasConfig(JaasUtils.java:59)
at org.apache.kafka.common.network.SaslChannelBuilder.configure(SaslChannelBuilder.java:85)

Этот файл jaas представляет собой прямую копию файла, который я использую в Java-приложении, которое взаимодействует с Kafka, и он работает, однако здесь, с использованием консоли инструменты, это просто не работает. Я пытался найти решение, но не нашел ничего полезного.

Может ли кто-нибудь мне с этим помочь?

Подробнее здесь: https://stackoverflow.com/questions/457 ... aas-config