首页 > 代码库 > java客户端作为kafka的consumer报错org.I0Itec.zkclient.exception.ZkTimeoutException
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
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。