[ 
https://issues.apache.org/jira/browse/KAFKA-2636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15177559#comment-15177559
 ] 

Rajesh Nair commented on KAFKA-2636:
------------------------------------

[~gwenshap]

You reasoning sounds correct!

But the problem is even after retry attempt fails , it does not throw an 
exception ( which is what an API user would expect).
We are running into this same problem with kafka 0.8.2 with async send.
Is there any other way of knowing network connection failure either at startup 
time or after kafka producer is running and producing messages.




> 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.3.4#6332)

Reply via email to