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
