It's a known issue: https://issues.apache.org/jira/browse/KAFKA-6520
On 2/20/19 3:25 AM, Javier Arias Losada wrote: > 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. >
signature.asc
Description: OpenPGP digital signature
