I get this error quite a lot:
kafka.consumer.SimpleConsumer: Reconnect due to socket error: java.nio.channels.ClosedByInterruptException
And this is followed by:
kafka.consumer.ConsumerFetcherThread:Shutting down
Any lights on this would be helpful!!!