Hello, Thank your for the quick reply. I will wait for 0.8.3.
Regards, /David On 31 July 2015 at 10:18, Stevo Slavić <ssla...@gmail.com> wrote: > Hello David, > > It's a known issue, see https://issues.apache.org/jira/browse/KAFKA-1788 > and https://issues.apache.org/jira/browse/KAFKA-2120 > > Kind regards, > Stevo Slavic. > > On Fri, Jul 31, 2015 at 10:15 AM, David KOCH <dk...@ezakus.com> wrote: > > > Hello, > > > > The new producer org.apache.kafka.clients.producer.KafkaProducer seems to > > block on send calls when the cluster is unavailable. > > > > How do I disable this and make send calls fast fail in the event of > > unavailable brokers? I know the 0.8.1 Scala-based producer did not block > in > > that case. > > > > Regards, > > > > /David > > > > > > > > The polling errors I get periodically for each unavailable broker: > > <156>1 2015-07-31T07:12:22.026Z - Audit [ezakus@18060 level="WARN" > > logger="org.apache.kafka.common.network.Selector"] Error in I/O with > > stag-xxxx-002/xx.xxx.xx.xxx > > java.net.ConnectException: Connection refused > > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > > at > > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739) > > at org.apache.kafka.common.network.Selector.poll(Selector.java:238) > > at > org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191) > > at > > org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122) > > at java.lang.Thread.run(Thread.java:745) > > >
