返回到文章

采纳

编辑于 1年前

librdkafka消费一段时间后报错REQTMOUT...Timed out FetchRequest in flight

kafka kafka消费者 librdkafka

kafka版本2.6.0

kafka正常运行,跨网域分布式部署,消费者远程消费broker消息,正常消费一段时间后报错:

%5|1677555150.963|REQTMOUT|rdkafka#consumer-2| [thrd:ssl://IP:9093/bootstrap]: ssl://IP:9093/0: Timed out FetchRequest in flight (after 61305ms, timeout #0)
%4|1677555150.963|REQTMOUT|rdkafka#consumer-2| [thrd:ssl://IP:9093/bootstrap]: ssl://IP:9093/0: Timed out 1 in-flight, 0 retry-queued, 0 out-queue, 0 partially-sent requests
%3|1677555150.967|FAIL|rdkafka#consumer-2| [thrd:ssl://IP:9093/bootstrap]: ssl://IP:9093/0: 1 request(s) timed out: disconnect (after 251161ms in state UP, 1 identical error(s) suppressed)
% ERROR CALLBACK: rdkafka#consumer-2: Local: Timed out: ssl://IP:9093/0: 1 request(s) timed out: disconnect (after 251161ms in state UP, 1 identical error(s) suppressed), error code [-185]

大概每60000ms报一次(1min),session.timeout.ms, heartbeat.interval.., request.timeout.ms等均采用的默认配置。

消费断断续续,时好时坏。