0

低于错误。不确定有什么问题。

%5|1591739081.630|REQTMOUT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/290: Timed out HeartbeatRequest in flight (after 10622ms, timeout #0)
%4|1591739081.630|REQTMOUT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/290: Timed out 1 in-flight, 0 retry-queued, 0 out-queue, 0 partially-sent requests
%4|1591739094.726|METADATA|rdkafka#consumer-1| [thrd:main]: GroupCoordinator/289: Metadata request failed: partition assignor: Local: Broker node update (-336618544ms): Permanent
4

1 回答 1

0

据我所知，这个错误来自经纪人的超时。

它基于session.timeout.ms消费者的，默认值是10000如果消费者不能在10秒内完成心跳，他将被踢出。

消费者尝试每heartbeat.interval.ms毫秒发送一次心跳，默认为每 3 秒。

因此，假设您对 borkers 有超过 10 秒的连接问题，您可能被踢出群组并且消费者被关闭

来自librdkafka文档session.timeout.ms：

客户端组会话和故障检测超时。消费者定期发送心跳 (heartbeat.interval.ms) 以向代理指示其活跃性。如果代理在会话超时内没有收到组成员的心，代理将从组中删除消费者并触发重新平衡。允许的范围使用代理配置属性 group.min.session.timeout.ms 和 group.max.session.timeout.ms 进行配置。另请参阅 max.poll.interval.ms。类型：整数

于 2020-06-16T08:38:39.540 回答