Re: kafka.consumer.ConsumerTimeoutException

2016-03-23 Thread Ratha v
Forgot to mention, I'm using kafka 2.11 version On 24 March 2016 at 16:55, Ratha v wrote: > Hi all; > > I'm new to kafka and wrote a simple multithreaded kafka consumer. when try > to consume the messages,It continuously throwing timeoutexception..How can > i get rid of this? > > I have multiple

kafka.consumer.ConsumerTimeoutException

2016-03-23 Thread Ratha v
Hi all; I'm new to kafka and wrote a simple multithreaded kafka consumer. when try to consume the messages,It continuously throwing timeoutexception..How can i get rid of this? I have multiple topics. *Executor* public class MessageListener { private Properties properties; private Consumer