Hi Liwu,
Correct me if I am wrong.
When calling the method ConsumerConnector.shutdown(), it will send
"ZookeeperConsumerConnector.shutdownCommand" to the queue, not set
ConsumerIterator's state is NOT_READY directly. So the consumer will continue
consuming until get the shutdownCommand in the q
Can you reproduce this with the latest version of Kafka?
best,
Colin
On Wed, Feb 15, 2017, at 22:29, 揣立武 wrote:
>
> Hi,all! Our program uses the high level consumer api(the version is
> 0.8.x). Sometimes the program will throw an exception in the 42th row in
> kafka.utils.IteratorTemplate class
