karaf-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jean-Baptiste Onofré (JIRA) <j...@apache.org>
Subject [jira] [Created] (KARAF-4430) Kafka appender should deal with the ConnectException when the Kafka broker is not available
Date Mon, 21 Mar 2016 17:29:25 GMT
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)

Mime
View raw message