Also, reading java docs for KafkaConsumer#poll(timeout) states: @param timeout The time, in milliseconds, spent waiting in poll if data is not available. If 0, returns * immediately with any records that are available now. Must not be negative.
Yet even setting it to 0 brings no joy. Cheers Oleg On Jul 28, 2016, at 3:43 PM, Oleg Zhurakousky <ozhurakou...@hortonworks.com<mailto:ozhurakou...@hortonworks.com>> wrote: So I have KafkaConsumer that is deliberately set with server properties pointing to non-running broker. Doing KafkaConsumer.poll(100) blocks infinitely even though ‘fetch.max.wait.ms’ is set to 1 millisecond. Basically I am trying to fail when connection is not possible. Any idea how to accomplish that? Cheers Oleg