Re: poll method thread

2016-04-27 Thread Spico Florin
Hi, Liquan! Thank you for your response. Is much more clear now. Regards, Florin On Sun, Apr 24, 2016 at 9:54 PM, Liquan Pei wrote: > Hi Spico, > > Kafka Consumer is single threaded which means all operations such as > sending heart beat, fech records and maintain group membership are done i

Re: poll method thread

2016-04-24 Thread Liquan Pei
Hi Spico, Kafka Consumer is single threaded which means all operations such as sending heart beat, fech records and maintain group membership are done in the same thread as the caller. Also, poll() is a blocking method with timeout and you can interrupt it with the wakeup method in Kafka Consumer

poll method thread

2016-04-24 Thread Spico Florin
hi! i would like to ask if the kafka consumer poll method is done in aseprated thread than the caller or in the same thread as the caller? it is syncriunous blocking method or asynch? thank you florin