使用sasl的kafka zookeeper安全认证与授权(jaas)

h5qlskok  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(1047)

关于使用digest md5身份验证的kafka zookeeper安全性,我正在尝试旋转/更改服务器(zookeeper)和客户端(kafka)jaas配置文件的凭据/密码。我们有一个由3个zookeers和3个kafka代理节点组成的3节点集群,下面是jaas配置文件。
Kafka.conf

org.apache.zookeeper.server.auth.DigestLoginModule required
username="super"
password="password";
};

Zookeeper.conf

Server {
org.apache.zookeeper.server.auth.DigestLoginModule required
user_super="password";
};

为了循环,我们在更新凭证(密码)之后对服务器(zookeeper)示例进行滚动重启,并在更新相同的凭证/密码之后进行滚动重启 super 我们注意到,一次一个客户端(kafka示例)的用户

[2019-06-15 17:17:38,929] INFO [ZooKeeperClient] Waiting until connected. (kafka.zookeeper.ZooKeeperClient)
[2019-06-15 17:17:38,929] INFO [ZooKeeperClient] Connected. (kafka.zookeeper.ZooKeeperClient)

服务器日志中的这些信息级别,最终导致代理不干净地关闭和重新启动,从而影响写入和读取的时间超过预期。我试过评论 requireClientAuthScheme=sasl 在zookeeper zoo.cfg中https://cwiki.apache.org/confluence/display/zookeeper/client-server+mutual+authentication 允许任何客户端向zookeeper进行身份验证,但没有成功。
另外,另一种方法-尝试使用动态更新jaas配置文件中的凭证/密码 sasl.jaas.config 并在本jira中记录相同的异常(参考:https://issues.apache.org/jira/browse/kafka-8010). 有人有什么建议吗?提前谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题