Hello Kafka users, working on a Kafka-Streams stateless application; we want to implement some healthchecks so that whenever connection to Kafka is lost for more than a threshold, marke the instance as unhealthy, so that our cluster manager (could be K8S or AWS-ECS) kills that instance and starts a new one.
We have notice that when the consumer is running and the connection is lost, it tries to reconnect and sends some logs, but we didn't find a way to programatically check or subscribe to the connection status. Am I missing something? Is this an intended feature? Why? What are the best practices for healtchecking Kafka-streams applications? I also found that with a plain Kafka consumer, no exception is raised on lost connectivity... how could we somehow check the connection status? How are other people solving this issue? Thank you very much.
