Kafka 客户端TimeoutException问题之坑
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kafka 客户端TimeoutException问题之坑相关的知识,希望对你有一定的参考价值。
参考技术A 会抛出org.apache.kafka.common.errors.TimeoutException:message可能为各种:
原因是发布到zookeeper的advertised.host.name如果没有设置,默认取 java.net.InetAddress.getCanonicalHostName(). 值,被用于生产端和消费端。因此外部网络或者未配置hostname映射的机器访问kafka集群时就会有网络问题了。
原因是kafka客户端连接到broker是成功的,但连接到集群后更新回来的集群meta信息是错误的即是会返回的是节点的hostname,解决办法就是手动配置advertised.host.name和advertised.port,2个参数都必须配置,重启问题解决:
dubbo 超神响应异常: com.alibaba.dubbo.remoting.TimeoutException: Waiting server-side response timeout.(示例代
因为dubbo默认的时间是500ms,超过这个时间它会重新请求服务层,最多尝试三次。
如果数据量比较大就不行了显示出来的异常为timeout。
在服务提供端设置timeout=1200000
并且加了timeout属性的配置因该放在最后一条,否则会配置冲突。
客户端添加timeout会造成tomcat启动延时。
<dubbo:service interface="com.XXXX.MyService" ref="myService" timeout="1200000"/>
另外一种是全局新修改的办法
<dubbo:provider delay="-1" timeout="60000" retries="0"/>
以上是关于Kafka 客户端TimeoutException问题之坑的主要内容,如果未能解决你的问题,请参考以下文章
向 kafka 主题发送消息时出现 TimeoutException
Kafka 生产者 TimeoutException: Expiring 1 record(s)
scala中的Flink Kafka程序给出超时错误org.apache.kafka.common.errors.TimeoutException:60000毫秒后更新元数据失败
kafka.common.errors.TimeoutException:Timeout expired while fetching topic metadata
org.apache.kafka.common.errors.TimeoutException: Topic not present in metadata 解决方法