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 解决方法

Kafka升级v1.1的错误以及性能总结