[jira] [Created] (KARAF-4430) Kafka appender should deal with the ConnectException when the Kafka broker is not available

["Jean-Baptiste Onofré (JIRA)" <ji...@apache.org>]

Jean-Baptiste Onofré created KARAF-4430:
-------------------------------------------

             Summary: Kafka appender should deal with the ConnectException when the Kafka broker is not available
                 Key: KARAF-4430
                 URL: https://issues.apache.org/jira/browse/KARAF-4430
             Project: Karaf
          Issue Type: Improvement
          Components: decanter
            Reporter: Jean-Baptiste Onofré
            Assignee: Jean-Baptiste Onofré
             Fix For: decanter-1.1.0


If the kafka appender is loosing the connection to the broker, we see a lot of exception in the log:

{code}
2016-03-21 17:32:50,032 | WARN  | ead | producer-2 | Selector                         | 59 - org.apache.servicemix.bundles.kafka-clients - 0.8.2.2_1 | Error in I/O with latitude/127.0.1.1
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)[:1.8.0_45]
        at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)[:1.8.0_45]
        at org.apache.kafka.common.network.Selector.poll(Selector.java:238)[59:org.apache.servicemix.bundles.kafka-clients:0.8.2.2_1]
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)[59:org.apache.servicemix.bundles.kafka-clients:0.8.2.2_1]
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)[59:org.apache.servicemix.bundles.kafka-clients:0.8.2.2_1]
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135)[59:org.apache.servicemix.bundles.kafka-clients:0.8.2.2_1]
        at java.lang.Thread.run(Thread.java:745)[:1.8.0_45]
{code}

This can lead to lot of noise, and "block" the container to shutdown. The kafka appender should define kind of connection timeout and fully disconnect.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)