spring kafka客户端无法从启用kerberos的kafka代理主题获取消息

w8f9ii69  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(365)

我们最近已经将kafka集群kerberized了,并且在读取代理上的主题中的消息时开始出现问题。
我们使用的是SpringKafka 1.1.2.release和kafka客户端0.10.0.1。
在阅读了apachekafka文档中的建议之后,我在项目中做了以下更改。
在使用者属性中添加security.protocol sasl\u明文。
添加了适当的jaas文件并在vm参数中提供了路径。
添加了krb5.conf并在vm参数中提供了路径。
我已经在jaas文件中创建并提供了相应的keytab条目。
在发布这些更改之后,我能够在没有问题的情况下启动应用程序(调试或跟踪中没有错误),并且在日志中看到与代理的连接是成功的。我还检查了tcp连接,结果显示客户端和服务器通信良好。
但是,问题是我无法接收来自主题的消息,并且在日志中看不到任何错误。
有什么我遗漏的或任何其他方式我可以解决?

icomxhvb

icomxhvb1#

好的-我们现在已经解决了这个问题,我们的kafka管理员为kerberos主体为正确的使用者组和正确的主题设置了正确的acl(权限)。
参考https://cwiki.apache.org/confluence/display/kafka/kafka+authorization+command+line+interface 了解更多信息

相关问题