2017-05-26 34 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的權限,以便能夠接收來自主題的消息。儘管如此,仍然在調查根本原因。 –

回答

相關問題