kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Oleg Zhurakousky <ozhurakou...@hortonworks.com>
Subject KafkaConsumer blocks indefinitely when server settings are wrong
Date Thu, 28 Jul 2016 19:43:42 GMT
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

Mime
View raw message