Re: Kafka Consumer poll

Hi, Sorry, i have one more query regarding consumer.poll() As KafkaConsumer fetches record when it is available irrespective of poll(timeout), does KafkaConsumer splits the poll(timeout) in to multiple intervals and checks Kafka Server for any messages. Eg., poll timeout is 10min , does it

Re: Kafka Consumer poll

Hi, Thanks for your reply Kamal and Oleg. Thanks and Regards A.SathishKumar >Also keep in mind that unfortunately KafkaConsumer.poll(..) will deadlock >regardless of the >timeout if connection to the broker can not be established and won't react to >thread interrupts. >This essentially

Re: Kafka Consumer poll

Also keep in mind that unfortunately KafkaConsumer.poll(..) will deadlock regardless of the timeout if connection to the broker can not be established and won't react to thread interrupts. This essentially means that the only way to exit is to kill jvm. This is all because Kafka fetches topic

Re: Kafka Consumer poll

See the answers inline. On Tue, Aug 2, 2016 at 12:23 AM, sat wrote: > Hi, > > I am new to Kafka. We are planning to use Kafka messaging for our > application. I was playing with Kafka 0.9.0.1 version and i have following > queries. Sorry for asking basic questions. > >

Kafka Consumer poll

Hi, I am new to Kafka. We are planning to use Kafka messaging for our application. I was playing with Kafka 0.9.0.1 version and i have following queries. Sorry for asking basic questions. 1) I have instantiated Kafka Consumer and invoked consumer.poll(Long.MAX_VALUE). Although i have specified