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. Thanks, Liquan On Sun, Apr 24, 2016 at 11:43 AM, Spico Florin <spicoflo...@gmail.com> wrote: > 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 > -- Liquan Pei Software Engineer, Confluent Inc
