出错现象:
java客户端编程作为kafka的消费端,连接kafka的broker报错
出错原因分析:
当服务器配置或者网络环境较差时,会出现连接zk超时的情况出现;
解决方法:将程序中的timeout数值调大
props.put("zookeeper.session.timeout.ms", "15000");
时间: 2024-12-28 01:27:52
出错现象:
java客户端编程作为kafka的消费端,连接kafka的broker报错
出错原因分析:
当服务器配置或者网络环境较差时,会出现连接zk超时的情况出现;
解决方法:将程序中的timeout数值调大
props.put("zookeeper.session.timeout.ms", "15000");