Kafka Zookeeper Connection Error Listener

[Joe San <co...@gmail.com>]

I have a Kafka broker and Zookeeper running locally. I use the high level
consumer API to read messages from a topic. Now I manually disconnect /
shutdown the Zookeeper instance running on my local machine.

I can see in my consumer logs the following:

20160215-16:03:43.110+0100
[kafka-consumer-akka.actor.default-dispatcher-4-SendThread(127.0.0.1:2181)]
WARN  org.apache.zookeeper.ClientCnxn - Session 0x152e4506a8f0005 for
server null, unexpected error, closing socket connection and attempting
reconnect
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_60]
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
~[na:1.8.0_60]
at
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
~[zookeeper-3.4.6.jar:3.4.6-1569965]
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081)
~[zookeeper-3.4.6.jar:3.4.6-1569965]

It is trying to re-connect, is there a way that I could in my consumer
application hook into this exception? I do not see any methods exposed by
the ConsumerConnector API that would let me know the connection status to
Zookeeper. Any ideas as to from where could I get this information about
Zookeeper connection status in my consumer application?