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 you have an easy way for implementing such thing I'll appreciate it. I'm using JAVA with the 0.8.1.1 kafka version library
Thanks!!
