Kafka 客戶端TimeoutException問題之坑

各種TimeoutException問題

會拋出org.apache.kafka.common.errors.TimeoutException:
message可能為各種：

  • Batch Expired
  • Failed to update metadata after 60000 ms.
  • ailed to update metadata after
  • ...

原因

原因是發(fā)布到zookeeper的advertised.host.name如果沒有設置，默認取java.net.InetAddress.getCanonicalHostName().值，被用于生產(chǎn)端和消費端。因此外部網(wǎng)絡或者未配置hostname映射的機器訪問kafka集群時就會有網(wǎng)絡問題了。

原因是kafka客戶端連接到broker是成功的，但連接到集群后更新回來的集群meta信息是錯誤的即是會返回的是節(jié)點的hostname，解決辦法就是手動配置advertised.host.name和advertised.port，2個參數(shù)都必須配置，重啟問題解決：

advertised.host.name=10.0.0.100
advertised.port=9092
最后編輯于 ：
?著作權歸作者所有,轉載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

相關閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容