Hey,
I want to create a monitor in my code which sample the Kafka connection and updates a file according to connection status (connected\disconnected).
Unfortunately, I couldn't find any field in the "ConsumerConnector" class or any other class which indicates what is the status of the connection. (for example: how can I determine if the process called ConsumerConnector.shutdown() ?)
Basically I need only to know if we are connected to Kafka or not.
If someone has an easy way for implementing such thing I'll appreciate it.
thanks!!