. Advertisement .
..3..
. Advertisement .
..4..
I asked here because I believe someone might help me. May someone tell me when trying to undefined, how to attempt to heartbeat failed since group is rebalancing? Thanks for your support.
Sign Up to our social questions and Answers Engine to ask questions, answer people’s questions, and connect with other people.
Login to our social questions & Answers Engine to ask questions answer people’s questions & connect with other people.
Lost your password? Please enter your email address. You will receive a link and will create a new password via email.
Please briefly explain why you feel this question should be reported.
Please briefly explain why you feel this answer should be reported.
Please briefly explain why you feel this user should be reported.
The cause:
This is the reason for heartbeat failure for group because it’s rebalancing. The fundamental way to determine whether all consumers are still functional is to listen for heartbeats. If you see a heartbeat failure when the group rebalances, it means that your consumer instance delayed too long to submit the next heartbeat, at which point the group deemed it dead and initiated a rebalance.
Solution:
To avoid this, you may either lengthen the timeout
(session.timeout.ms)
or make sure your customer transmits heartbeats more frequently(heartbeat.interval.ms)
. Because heartbeats are essentially built intopoll()
, you must call poll often enough. This is often accomplished by limiting the number of records that a single poll returns using themax.poll.records
setting (to reduce the time needed to process all of the fetched data).