Problems encountered during the consumer shutdown.

[paresh shah]

We are interrupting the thread that uses the consumer connector. The question I 
had was if the LeaderFinderThread is interruptible then it is one that is 
generating the exception due to the await() call( highlighted )

  def shutdown(): Unit = {
    info("Shutting down")
    isRunning.set(false)
    if (isInterruptible)
      interrupt()
    shutdownLatch.await()
    info("Shutdown completed")
  }

The above is invoked as a part of the ConsumerFetcherManager.stopConnections() 
in the shutdown path. In this case should the shutdown() method not explicitly 
catch the exception around the call to stopConnections().

Please confirm if my understanding is correct.

thanks
Paresh