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:

2016-03-21 17:32:50,032 | WARN  | ead | producer-2 | Selector                         | 59
- org.apache.servicemix.bundles.kafka-clients - | Error in I/O with latitude/
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:]
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)[59:org.apache.servicemix.bundles.kafka-clients:]
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)[59:org.apache.servicemix.bundles.kafka-clients:]
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135)[59:org.apache.servicemix.bundles.kafka-clients:]
        at java.lang.Thread.run(Thread.java:745)[:1.8.0_45]

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

View raw message