卡夫卡到动物园管理员摘要-md5认证错误

Question

我可以使用kafka broker和embedded zookeeper (由Kafka提供)对MD5进行摘要-MD5身份验证，但在执行摘要时我得到了以下错误消息:使用Kafka broker和非嵌入式动物园管理员(单独的动物园管理员实例)进行MD5身份验证。

以下是错误消息：

[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

Answer 1

你的文件是什么样子的？

对于动物园管理员集群，您必须在动物园管理员jaas文件中有三个部分：服务器、QuorumServer和QuorumLearner

QuorumServer和QuorumLearner节用于相互对动物园管理员服务器进行身份验证。参见§摘要-基于md5的身份验证中的配置这里示例。

服务器部分用于对kafka代理进行身份验证。它应该包含kafka用户名和密码，如§服务器配置/ JAAS配置文件中所示的这里格式:摘要-MD5身份验证。

您的Kafka文件应该有一个带有用户名和密码的客户端部分，如§客户端配置/ jaas配置文件:摘要-md5身份验证中所示的这里。

最后，检查是否使用了正确的环境变量作为文件：

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

嵌入式动物园管理员使用KAFKA_OPTS