You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ismael Juma (JIRA)" <ji...@apache.org> on 2017/10/30 11:54:00 UTC
[jira] [Resolved] (KAFKA-2636) Producer connectivity obscured
connection failure logging
[ 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)