subject:"Kafka exception"

Re: Kafka exception

2017-02-19 Thread Yuanjia

nCommand in the queue. Is there any exception information when calling the method ConsumerIterator.makeNext()? Yuanjia Li From: 揣立武 Date: 2017-02-16 14:29 To: dev CC: users; 陈希; 涂扬 Subject: Kafka exception Hi,all! Our program uses the high level consumer api(the version is 0.8.x). Someti

Re: Kafka exception

2017-02-17 Thread Colin McCabe

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

Kafka exception

2017-02-15 Thread 揣立武

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，the content is "throw new IllegalStateException("Expected item but none found.")". I think it is a race condition pro