原文:java代碼向kafka集群發送消息報org.apache.kafka.common.errors.TimeoutException: Batch Expired

由於項目是springboot項目,在application.properties加入 logging.level.root debug debug日志報錯信息為kafka集群ip別名訪問失敗 在windows上配置ip別名 C: Windows System drivers etc hosts ...

2019-12-16 16:08 0 1014 推薦指數:

查看詳情

kafka2.11-0.9.0.0實現Producer發送消息時,無法發送,報錯信息:org.apache.kafka.common.errors.TimeoutException: Batch Expired

最開始在本機搭建了kafka集群,本地 producer 客戶端成功發布消息至 broker。隨后在服務器(虛擬機)上搭建了 kafka 集群,在本機連接該集群,producer 卻無法發布消息到 broker(奇怪也沒有拋錯)。最開始懷疑是 iptables 沒開放,於是開放端口,結果還不 ...

Thu Mar 19 22:47:00 CST 2020 0 1092
kafka producer batch 發送消息

Sender 類實現了 Runnable 接口,封裝了具體的邏輯,發送消息和接收響應都在這個類中。 3. 執行回調 ...

Sun Jan 06 20:38:00 CST 2019 0 851
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM