kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chinmay Soman <chinmay.cere...@gmail.com>
Subject Question regarding Kafka EventThread
Date Wed, 05 Aug 2015 19:12:15 GMT
Hey guys,

We're using Kafka version 0.8.2.0 and using the Java producer
(KafkaProducer) to write to a single Kafka broker with acks=1. There's a
callback defined on every produce request which takes corrective action if
the write fails.

What we see is that, if the broker is down for an extended period of time,
any write to the producer gets stuck, with this message:

[2015-08-05 12:02:04,743] WARN Error in I/O with /........
(org.apache.kafka.common.network.Selector:276)
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)

This goes on repeatedly and the callback is never invoked. Is there a way
to get the Kafka EventThread to give up after a while ?


-- 
Thanks and regards

Chinmay Soman

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message