Re: KafkaStream hasNext() blocking and I'm not sure why

2014-02-26 Thread Jun Rao
Could it be that one of those threads died? Java threadpool is notorious for eating exceptions. So, you probably want to try/catch the whole iteration block. Thanks, Jun On Wed, Feb 26, 2014 at 3:56 AM, Josh wrote: > Hi all, > > I have created 6 Kafka topics each with 2 partitions, and now I

KafkaStream hasNext() blocking and I'm not sure why

2014-02-26 Thread Josh
Hi all, I have created 6 Kafka topics each with 2 partitions, and now I want to consume from all partitions in a Java app. I have created a Executors.newScheduledThreadPool(12) for this, and then submit my KafkaConsumer implementations to this thread pool. In KafkaConsumer, I do: ConsumerIterato