Hello community,
 I am running a simple consumer for kafka such as this

   int timeout = 80000;
   int bufferSize = 64*1024;
   consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName);

This runs fine for a couple for hours but I get an exception later on 
kafka.consumer.SimpleConsumer: Reconnect due to socket error: 
java.nio.channels.ClosedChannelException

and consumer stops ... has anyone faced this problem before ?

Thanks
Shivpriya

Reply via email to