kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ismael Juma (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (KAFKA-2636) Producer connectivity obscured connection failure logging
Date Mon, 30 Oct 2017 11:54:00 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Ismael Juma resolved KAFKA-2636.
--------------------------------
    Resolution: Not A Problem

The producer should throw a TimeoutException to the callback or if `Future.get` is called.

> Producer connectivity obscured connection failure logging
> ---------------------------------------------------------
>
>                 Key: KAFKA-2636
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2636
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 0.8.2.1, 0.8.2.2
>         Environment: Windows 8 running java implementation of Kafka Producer
>            Reporter: Jason Kania
>
> The Kafka Producer does not generate a visible exception when a connection cannot be
made. Instead DEBUG settings are required to observe the problem as shown below:
> [2015-10-12 21:23:20,335] DEBUG Error connecting to node 0 at 482f4769eed1:9092: (org.apache.kafka.clients.NetworkClient)
> java.io.IOException: Can't resolve address: 482f4769eed1:9092
> 	at org.apache.kafka.common.network.Selector.connect(Selector.java:138)
> 	at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:417)
> 	at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:116)
> 	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:165)
> 	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
> 	at java.lang.Thread.run(Unknown Source)
> Caused by: java.nio.channels.UnresolvedAddressException
> 	at sun.nio.ch.Net.checkAddress(Unknown Source)
> 	at sun.nio.ch.SocketChannelImpl.connect(Unknown Source)
> 	at org.apache.kafka.common.network.Selector.connect(Selector.java:135)
> 	... 5 more
> [2015-10-12 21:23:20,358] DEBUG Initiating connection to node 0 at 482f4769eed1:9092.
(org.apache.kafka.clients.NetworkClient)
> Secondly, the errors do not identify the node by IP address making error investigation
more difficult especially when learning to use Kafka.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message