Kafka的Consumer无法启动答案

【问题标题】：Kafka's Consumer can't startKafka的Consumer无法启动
【发布时间】：2016-03-19 02:48:17
【问题描述】：

我键入如下命令行。但它显示它无法连接到 localhost:2181。我已经启动了 zookeeper。

bin/kafka-console-consumer.sh --zookeeper --localhost:2181 --topic pain --from-beginning

Exception in thread "main" org.I0Itec.zkclient.exception.ZkException: Unable to connect to --localhost:2181
at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:66)
    at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:876)
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98)
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84)
    at kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:171)
    at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:126)
at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:143)
at kafka.consumer.Consumer$.create(ConsumerConnector.scala:94)
at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:145)
at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
Caused by: java.net.UnknownHostException: --localhost
at java.net.InetAddress.getAllByName0(InetAddress.java:1252)
at java.net.InetAddress.getAllByName(InetAddress.java:1164)
at java.net.InetAddress.getAllByName(InetAddress.java:1098)
at org.apache.zookeeper.client.StaticHostProvider.init(StaticHostProvider.java:61)
at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:445)
at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:380)
at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:64)
... 9 more


[root@crxy2 kafka_2.10-0.8.2.0]# jps
5487 QuorumPeerMain
5862 Jps
5518 Kafka

[root@crxy2 kafka_2.10-0.8.2.0]# bin/kafka-topics.sh --zookeeper localhost:2181 --list
pain

【问题讨论】：

标签： hadoop apache-kafka apache-zookeeper flume

【解决方案1】：

应该是bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic pain --from-beginning

注意--zookeeper localhost:2181 而不是--zookeeper --localhost:2181

【讨论】：

【解决方案2】：

尝试以下命令：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9093 --topic pain --from beginning

在这里，我假设您的一个 kafka 代理或 kafka 服务器在 localhost：9093 上运行

如果不向任何一个活着的 kafka 代理提供地址作为参数 --bootstrap-server

【讨论】：

只需检查端口号：在我的情况下为 9092。查看 kafka.properties 文件并搜索 #listeners=PLAINTEXT://:9092