kafka consumer取数据卡顿

silent。 发表于: 2019-12-27   最后更新时间: 2019-12-27 15:19:48   1,994 游览

kafka多个consumer取数据时 每隔一段时间都会卡顿几十秒 打印debug日志如下

2019-12-27 11:00:53 [DEBUG]-[org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle(ConsumerCoordinator.java:790)] Offset commit for group testgroup failed: The coordinator is not aware of this member.
2019-12-27 11:00:53 [DEBUG]-[org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatResponseHandler.handle(AbstractCoordinator.java:777)] Attempt to heartbeat failed for group testgroup since member id is not valid.
发表于 2019-12-27
添加评论

1、检查物理网络是否稳定
2、消费者是否处理时间过长,导致超过默认30秒,则认为消费者已经失联,就会重新加入。

你的答案

查看kafka相关的其他问题或提一个您自己的问题