ivinayagam Muthuvinayagam [sankarm...@gmail.com]
Sent: Monday, May 11, 2015 6:26 PM
To: users@kafka.apache.org
Subject: Kafka listener threads - graceful shutdown
I am using the following code to help kafka stream listener threads to exit
out of the blocking call of hasNext() on the consumerIterato
I am using the following code to help kafka stream listener threads to exit
out of the blocking call of hasNext() on the consumerIterator. But the
threads never exit, when they receive allDone() signal. I am not sure
whether I am making any mistake. Please let me know is this right approach.
