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

出错现象:

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

出错原因分析:

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

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

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

时间: 2024-08-23 22:51:37

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

Java客户端连接kafka集群报错

往kafka集群发送消息时,报错如下: page_visits-1: 30005 ms has passed since batch creation plus linger time 加入log4j.properties,设置为DEBUG级别,错误如下: 2017-06-03 17:33:31,417 DEBUG [org.apache.kafka.clients.NetworkClient] - Error connecting to node 2 at kafka-cluster-64bi

kafka 单机测试 异常:ExceptiException in thread "main" org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 6000

遇到这个问题三天了,在网上搜索了很多文章都说把时间调大,不过对于我来说没有什么用处.今天在解决另一个问题顺便解决了这个问题,给以后遇到此问题的同学做一个参考. 解决办法:1.关闭Linux防火墙 2.或者让2181端口通过防火墙.命令:iptables -I INPUT -p tcp --dport 2181 -j ACCEPT

Control character in cookie value, consider BASE64 encoding your value , java操作cookie遇到中文会报错的解决方案

项目当中用到cookie保存中文,但是会报如下错误: Control character in cookie value, consider BASE64 encoding your value 大概意思是保存到cookie当中的值存在控制字符,无法保存.但实际上数据是不存在这种问题的.再看后面的那句话,好像是将要保存的值进行了base64编码,可能是因为中文在编码时出现乱码导致一些控制字符的出现.看来setCookie方法不支持保存中文(GBK)编码的样子. 解决方案:将要保存的值进行URLE

java菜鸟篇<二> eclipse启动tomcat报错的问题:Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "main"

9.1今天不知道自己瞎搞eclipse的时候按到了什么键,然后再启动程序的时候就会报错: 如下: Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "main"(溢出内存错误) 解决方案: 然后就发现自己原来设置扩大堆内存的没有了,要重新设置 如图: 重新启动项目,OK解决了!!哈哈哈

dovecot并发数造成foxmail、outlook等客户端工具接收邮件有时候报错

问题:dovecot并发数造成foxmail.outlook等客户端工具接收邮件有时候报错,频繁点收取邮件报错. /var/log/maillog日志有大量的报错: Jan 24 14:01:33 mail dovecot: imap-login: Error: read(imap) failed: Remote closed connection (service's process_limit reached?) 1.看报错应该是dovecot最大并发数的问题(默认是2048),使用这个命令

dovecot vsz_limit参造成foxmail、outlook等客户端工具接收邮件有时候报错

问题:dovecot并发数造成foxmail.outlook等客户端工具接收邮件有时候报错,关闭客户端工具后又可以了. /var/log/maillog日志有大量的报错: Jan 25 08:18:35 localhost dovecot: auth: Fatal: master: service(auth): child 60976 returned error 83 (Out of memory (service auth { vsz_limit=256 MB }, you may need

java插入数据至mysql数据库报错:check the manual that coresponds to your mysql server version for the right syntax to use near 'condition)values...解决方案

MySQL5.X(本地数据库) 使用java向表中插入数据时,每次数据库更新,pstm.executeUpdate();就会跳到IO报错,提示原因是sql语法有问题,如题可见 当测试插入数据不含condition字段时,插入成功,尝试更名为conDition时,仍报错 解决方案: 更改condition为conDi,原因可能时因为condition为数据库或java关键字不能使用,更名后不再受影响,插入成功. java插入数据至mysql数据库报错:check the manual that c

Cobbler安装报错--dhcpd -t failed Exception occured: <class 'cobbler.cexceptions.CX'>

最近想玩一下自动化安装,就研究了一下cobbler,测试环境本来是想用CentOS6.X的,但是后来一想,还是想用CentOS7.X.然后就碰到坑了. 在同步cobbler配置的时候,发现了以下错误: cobbler  sync dhcpd -t failedException occured: <class 'cobbler.cexceptions.CX'>Exception value: 'cobbler trigger failed: cobbler.modules.sync_post_

zookeeper_service 出错 java.lang.NoClassDefFoundError: org/I0Itec/zkclient/exception/ZkNoNodeException

2016-12-18 08:28:07 ContextLoader:358 ERROR - Context initialization failed java.lang.NoClassDefFoundError: org/I0Itec/zkclient/exception/ZkNoNodeException 解决: 在pom.xml加入 <dependency> <groupId>com.101tec</groupId> <artifactId>zkcli