我已经成功地为Kafka经纪人设置了sasl纯文本和纯文本安全,从某种意义上说,客户如果不提供 kafka_client_jaas.conf
由于身份验证失败,具有有效的用户名和密码凭据。
然而,我不能为zookeeper做同样的事情,例如 kafka_topics.sh
成功连接到zookeeper,而没有 KAFKA_OPTS
设置 java.security.auth.login.config
那会指向任何 jaas.conf
文件。我想它应该指向同一个方向 kafka_client_jaas.conf
作为控制台使用者和生产者,因为有一个客户机部分被定义为对zookeeper进行身份验证。我加了以下三行 zookeeper.properties
文件(我不知道第三行是用来做什么的):
authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
requireClientAuthScheme=sasl
jaasLoginRenew=3600000
我创造了 zookeeper_jaas.conf
(定义服务器部分)并启动zookeeper KAFKA_OPTS
指向它,并将客户机部分添加到 kafka_server_jaas.conf
这样经纪人就可以向zookeeper进行正确的身份验证,就像这里描述的那样:
KafkasaslZookeeper认证
但我不能在运行时引发身份验证失败 kafka_topics.sh
,如前所述。我哪里出错了?
暂无答案!
目前还没有任何答案,快来回答吧!