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