Hi team, I got java.nio.channels.ClosedByInterruptException when closing ConsumerConnector using kafka 0.8.2
Here is the exception 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [test12345_localhost], ZKConsumerConnector shutting down 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [ConsumerFetcherManager-1423479848796] Stopping leader finder thread 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [test12345_localhost], Shutting down 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [test12345_localhost], Shutdown completed 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [ConsumerFetcherManager-1423479848796] Stopping all fetchers 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [test12345_localhost], Stopped 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [ConsumerFetcherThread-test12345_localhost], Shutting down 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - Reconnect due to socket error: java.nio.channels.ClosedByInterruptException 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [ConsumerFetcherThread-test12345_localhost], Stopped 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [ConsumerFetcherThread-test12345_localhost], Shutdown completed 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [ConsumerFetcherManager-1423479848796] All connections stopped 2015-02-09 19:04:19 INFO org.I0Itec.zkclient.ZkEventThread:82 - Terminate ZkClient event thread. 2015-02-09 19:04:19 INFO org.apache.zookeeper.ZooKeeper:684 - Session: 0x14b6dd8fcf80011 closed 2015-02-09 19:04:19 INFO org.apache.zookeeper.ClientCnxn$EventThread:512 - EventThread shut down 2015-02-09 19:04:19 INFO kafka.utils.Logging$class:68 - [test12345_localhost], ZKConsumerConnector shutdown completed in 86 ms -- Regards, Tao