I'm doing kind of health-check stuff for consumers and would like to leverage current heartbeat state to do it. Like mark the consumer pod as failed once the heartbeat is failed. I found we could see the heartbeat failed logs but it seems that the heartbeat failure is not exposed as an event or an error by AIOKafka.
Is there a way that I can use to capture the heartbeat failure in my consumer code? Thanks
I'm doing kind of health-check stuff for consumers and would like to leverage current heartbeat state to do it. Like mark the consumer pod as failed once the heartbeat is failed. I found we could see the heartbeat failed logs but it seems that the heartbeat failure is not exposed as an event or an error by AIOKafka. Is there a way that I can use to capture the heartbeat failure in my consumer code? Thanks