問題描述:
運行生產者線程的時候顯示如下錯誤信息:
Expiring 1 record(s) for XXX-0: 30042 ms has passed since batch creation plus linger time
在自己部署Kafka時候遇到上面34100ms has passed since batch creation plus linger time at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:94)
問題排查:
1. 檢查網絡以及端口是否關閉:
telnet測試
2. 排查kafka配置文件
添加如下

3.啟動后問題解決
問題思考:
由於沒有對Kafka進行ip監聽導致問題
