解讀

生產對接，啟動消費端出現Attempt to heartbeat failed since group is rebalancing，它是kafka消費者組的心跳機制，用于檢測超時不能工作的消費者。
當有新的消費者加入的時候，kafka消費者組啟動rebalance機制，即重平衡，重新分配資源。同時檢測組內消費者成員是否可以正常工作。如果心跳檢測失敗，則會報Attempt to heartbeat failed since group is rebalancing

2021-07-21 15:58:58.574 INFO 18804 --- [ronmental-group] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-4, groupId=ds-BEnvironmental-group] Attempt to heartbeat failed since group is rebalancing 2021-07-21 15:59:01.611 INFO 18804 --- [ronmental-group] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-4, groupId=ds-BEnvironmental-group] Attempt to heartbeat failed since group is rebalancing 2021-07-21 15:59:04.636 INFO 18804 --- [ronmental-group] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-4, groupId=ds-BEnvironmental-group] Attempt to heartbeat failed since group is rebalancing

當超過max.poll.interval.ms這個時間時，消費者組會放棄檢測，將消費者從組內剔除，出現下圖異常信息

This member will leave the group because consumer poll timeout has expired. This means the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time processing messages. You can address this either by increasing max.poll.interval.ms or by reducing the maximum size of batches returned in poll() with max.poll.records.

總結

以上是生活随笔為你收集整理的kafka消费端Attempt to heartbeat failed since group is rebalancing的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。