报错：org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for myS

未知 02-07 3042

大家好，我是邵奈一，一个不务正业的程序猿、正儿八经的斜杠青年。 1、世人称我为：被代码耽误的诗人、没天赋的书法家、五音不全的歌手、专业跑龙套演员、不合格的运动员… 2、这几年，我整理了很多IT技术相关的教程给大家，主要是大数据教程，帮助了很多小伙伴入坑大数据行业。 3、如果您觉得文章有用，请收藏，转发，评论，并关注我，谢谢！博客导航跳转（请收藏）：邵奈一的技术博客导航 | 公众号 | 微信 | 微博 | CSDN | 简书 |

报错如下：

java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for mySecondTopic-2:120000 ms has passed since batch creation at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:98) at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:67) at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:30) at com.shaonaiyi.producer.MySecondProducer.main(MySecondProducer.java:31) Caused by: org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for mySecondTopic-2:120000 ms has passed since batch creation Process finished with exit code 0 org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for mySecondTopic-2:120000 ms has passed since batch creation Process finished with exit code 0

原因：Java API 方式生成者无法与Kafka连接

情况说明：

1、Kafka版本：kafka_2.12-2.3.0 2、部署方式为伪分布式，在一台机器上配置了三个server.properties文件

解决方案：在每个server.properties文件里面添加一句：

host.name=服务器的ip;

因为我在服务器上配置了域名映射，所以我配的是

host.name=主机名

问题解决！