0
点赞
收藏
分享

微信扫一扫

org.apache.kafka.common.errors.TimeoutException: Failed to send request after 30000 ms解决办法

最近使用kafka入Hologres碰到这个问题,作为新手的我研究很久终于解决这个问题,记录一下。

一、调大SESSION_TIMEOUT_MS_CONFIG和REQUEST_TIMEOUT_MS_CONFIG

org.apache.kafka.common.errors.TimeoutException: Failed to send request after 30000 ms解决办法_bc

二、调大FETCH_MAX_BYTES_CONFIG和MAX_PARTITION_FETCH_BYTES_CONFIG。 我这里之前设置了100K,现在设置为5M,解决问题。有兴趣的同学可以研究下kafka消费短参数,参数设置对了,可以解决大部分问题。

org.apache.kafka.common.errors.TimeoutException: Failed to send request after 30000 ms解决办法_kafka_02

三、Hologres可以使用HoloClient,进行批量入库,比jdbc的多线程入库要好。

举报

相关推荐

0 条评论