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
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