Hi all, Is there a standardized way to implement a health check for a Kafka Consumer? I.e. for an application that runs in Kubernetes w/liveness probes. There does not seem to be an exposed API method for the Consumer’s current state or anything similar.
The example issue we ran into was with one of our three broker’s being moved when an AWS node failed, and that broker was the coordinator for our Consumer. The consumer eventually reached the max.poll.ms and left the group, but no exceptions were thrown, no errors, so our applications error handling didn’t flag the consumer as dead. Thanks in advance! Upesh Upesh Desai Senior Software Developer ude...@itrsgroup.com www.itrsgroup.com Internet communications are not secure and therefore the ITRS Group does not accept legal responsibility for the contents of this message. Any view or opinions presented are solely those of the author and do not necessarily represent those of the ITRS Group unless otherwise specifically stated. [itrs.email.signature]
