java客户端作为kafka的consumer报错org.I0Itec.zkclient.exception.ZkTimeoutException

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java客户端作为kafka的consumer报错org.I0Itec.zkclient.exception.ZkTimeoutException相关的知识,希望对你有一定的参考价值。

出错现象:

java客户端编程作为kafka的消费端,连接kafka的broker报错

技术分享



出错原因分析:

当服务器配置或者网络环境较差时,会出现连接zk超时的情况出现;


解决方法:将程序中的timeout数值调大

props.put("zookeeper.session.timeout.ms", "15000");

以上是关于java客户端作为kafka的consumer报错org.I0Itec.zkclient.exception.ZkTimeoutException的主要内容,如果未能解决你的问题,请参考以下文章

如何创建kafka consumer

SpringBoot中使用Kafka报错:Failed to construct kafka consumer

kafka启动consumer报java.nio.channels.UnresolvedAddressException

kafka Create topic 报错

kafka 创建消费者报错 consumer zookeeper is not a recognized option

命令消费kafka报错(id: -1 rack: null) disconnected