Kafka to zookeeper Ошибка аутентификации DIGEST-MD5 - PullRequest
Новая
       38

Kafka to zookeeper Ошибка аутентификации DIGEST-MD5

0 голосов
/ 05 ноября 2018

Я мог выполнить аутентификацию DIGEST-MD5 с брокером kafka и встроенным zookeeper, который выдает Kafka, но я получал следующее сообщение об ошибке при выполнении аутентификации DIGEST-MD5 с брокером Kafka и не встроенным zookeeper (отдельный экземпляр zookeeper).

Пожалуйста, найдите ниже сообщение об ошибке: 

[2018-11-05 19:44:21,536] ERROR SASL authentication failed using login context 'Client' with exception: {} (org.apache.zookeeper.client.ZooKeeperSaslClient)

javax.security.sasl.SaslException: Error in authenticating with a Zookeeper Quorum member: the quorum member's saslToken is null.

org.apache.zookeeper.KeeperException$AuthFailedException: KeeperErrorCode = AuthFailed for /consumers

1 Ответ

0 голосов
/ 05 ноября 2018

Как выглядят ваши файлы jaas?

Для кластера Zookeeper в файле jaas zookeeper должно быть три раздела: Сервер , QuorumServer и QuorumLearner

Секции

QuorumServer и QuorumLearner используются для аутентификации серверов zookeeper друг для друга. См. Пример конфигурации здесь в § аутентификация на основе DIGEST-MD5

Сервер раздел используется для аутентификации брокеров Kafka. Он должен содержать имя пользователя и пароль kafka, отформатированные как показано здесь в § Файл конфигурации сервера / конфигурации JAAS: аутентификация DIGEST-MD5

Ваш файл Kafka jaas должен иметь раздел Client с именем пользователя и паролем, как показано здесь в § Файл конфигурации клиента / JAAS: аутентификация DIGEST-MD5

Наконец, убедитесь, что вы используете правильную переменную окружения для jaas-файла zookeeper: 

SERVER_JVMFLAGS="-Djava.security.auth.login.config=/path/to/server/jaas/file.conf"

Встроенный зоокейпер использует KAFKA_OPTS

...