Unsubscribe

2016-06-25 Thread Shivpriya Tamboskar 
Unsubscribe

Sent from my iPhone

-
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org

java.nio.channels.ClosedChannelException

2016-03-04 Thread Shivpriya Tamboskar 
Hello community,
 I am running a simple consumer for kafka such as this

   int timeout = 8;
   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