Antony Stubbs created KAFKA-6268:
------------------------------------
Summary: Tools should now swallow exceptions like resolving
network names
Key: KAFKA-6268
URL: https://issues.apache.org/jira/browse/KAFKA-6268
Project: Kafka
Issue Type: Bug
Components: core
Affects Versions: 0.11.0.1
Reporter: Antony Stubbs
The cli consumer client shows nothing when it can't resolve a domain. This and
other errors like it should be shown to the user by default. You have to turn
on DEBUG level logging in the tools log4j to find there is an error.
{{[2017-11-23 16:40:56,401] DEBUG Error connecting to node
as-broker-1-eu-west-1b-public:9092 (id: 1 rack: null)
(org.apache.kafka.clients.NetworkClient)
java.io.IOException: Can't resolve address: as-broker-1-eu-west-1b-public:9092
at org.apache.kafka.common.network.Selector.connect(Selector.java:195)
at
org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:764)
at
org.apache.kafka.clients.NetworkClient.access$600(NetworkClient.java:60)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:908)
at
org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:819)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:431)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:208)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:199)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:134)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:223)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:200)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:286)
at
org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1078)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1043)
at kafka.consumer.NewShinyConsumer.<init>(BaseConsumer.scala:64)
at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:72)
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
Caused by: java.nio.channels.UnresolvedAddressException
at sun.nio.ch.Net.checkAddress(Net.java:101)
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622)
at org.apache.kafka.common.network.Selector.connect(Selector.java:192)
... 18 more
}}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
