问题描述:
运行生产者线程的时候显示如下错误信息:
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监听导致问题