2017-05-26 66 views
0

我们最近有Kaker集群kerberized,我们开始在代理中读取主题中的消息时遇到问题。春季Kafka客户端无法从启用了Kerberos的Kafka Broker主题获取消息

我们使用spring kafka 1.1.2.RELEASE和kafka客户端0.10.0.1。

在完成Apache Kafka文档的建议后,我对项目进行了以下更改。

  1. 在消费者属性中添加了security.protocol SASL_PLAINTEXT。
  2. 添加了相应的JAAS文件并提供了VM参数中的路径。
  3. 添加了KRB5.conf并在VM参数中提供了路径。
  4. 我在JAAS文件中创建并提供了相应的keytab条目。

发布此更改,我能够调出没有问题的应用程序(在调试或跟踪没有错误),我在日志中看到与代理的连接是成功的。 我也检查了TCP连接,它显示客户端和服务器通讯良好。

但是,问题是我无法接收来自主题的消息,并且在日志中看不到任何错误。

有什么我失踪或任何其他方式,我可以排除故障?

+0

在最近的版本中,我们增加了Kerberos配置到春节卡夫卡:https://github.com/spring-projects/spring-kafka/issues/201。但看起来与你的问题完全无关。检查卡夫卡经纪人记录一些线索。 –

+0

是的,我已经要求我的kafka管理员在代理上设置日志级别为DEBUG。我会更新我的研究结果。 –

+0

好的 - 看起来像卡夫卡管理员已经温和地提升了我的ID的权限,以便能够接收来自主题的消息。尽管如此,仍然在调查根本原因。 –

回答