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.
1、检查物理网络是否稳定
2、消费者是否处理时间过长,导致超过默认30秒,则认为消费者已经失联,就会重新加入。
你的答案