kafka问题集锦

一. org.apache.kafka.common.errors.TimeoutException: Batch Expired

问题描述:通过java客户端访问kafka服务器,当生产者线程向kafka插入数据时候出现该错误

问题分析:批处理过期

1.检查kafkaip地址是否访问正常

telnet ip port

 

2. 正常情况下,检查配置文件是否配置正确

在config/server.properties中加入如下属性

advertised.host.name=你的ip地址

  问题解决:如第二步所示

二.org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 3000 ms

问题描述:通过生产者产生后,插入到kafka中出现该错误

问题解决:检查其kafka中bootstrap.servers是否配置正确

原文地址:https://www.cnblogs.com/lonecloud/p/9287750.html