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


Reply via email to