Re: Kafka 0.9 API connection refused exception not raised to client code

Hmm, as a newbie with Kafka v0.9 and having tested this scenario, this is what is happening: You can reproduce failure by setting just BOOTSTRAP_SERVERS_CONFIG, by not passsing custom timeouts, it should then invoke your callback in producer.send(record, new ProducerCallback(record)); with "org.ap

Kafka 0.9 API connection refused exception not raised to client code

Hi kafka folks, I've written some code to test Kafka brokers using the Kafka 0.9 API (I need Kerberos support). It appears the 0.9 API is trapping broker connection refused exception at a lower level and retrying in a loop (visible only at debug log level), when I actually want it to fail and rai