Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2636

Producer connectivity obscured connection failure logging

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Not A Problem
    • 0.8.2.1, 0.8.2.2
    • None
    • None
    • None
    • Windows 8 running java implementation of Kafka Producer

    Description

      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.

      Attachments

        Activity

          People

            Unassigned Unassigned
            longtimer Jason Kania
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: