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