尝试连接到Kafka时无可用经纪人错误

Question

当尝试在 CentOS 上使用 Python 客户端本地连接到 Kafka 0.10.0.0 时，我有一个非常奇怪的问题。

我的连接选项非常简单且默认：

kafka_consumer = kafka.KafkaConsumer(
        bootstrap_servers=['localhost:9092'],
        client_id="python-test-consumer"
    )

当我在Kafka的服务器中手动设置侦听器选项时。属性文件，如：

listeners=PLAINTEXT://localhost:9092

我得到了kafka.errors。NoBrokersAvailable，尽管我仍然可以使用curl或其他linux工具轻松连接到Kafka代理服务器。

无广告。侦听器或其他不推荐使用的广告选项有助于解决该问题。因此，唯一有效的配置状态是没有监听器的状态。这肯定是不可接受的，因为我们需要以某种方式设置本地集群。

似乎这个愚蠢问题的解决方案很简单，并且四处思考，但我们自己无法弄清楚。

Answer 1

这听起来可能很傻，但是同样的问题也因为这个发生在我身上:

我通过brew (Mac包管理器)升级到了Kafka 0.10.0.0。Brew然后建议像这样运行一行程序:

$ zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties; kafka-server-start /usr/local/etc/kafka/server.properties

而不是我以前的执行方式：

$ zkServer start
$ kafka-server-start /usr/local/etc/kafka/server.properties

该方法建议在客户中不断抛出“无可用经纪人”错误。然后我将命令拆分为两行：

$ zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties
$ kafka-server-start /usr/local/etc/kafka/server.properties

一切都像以前一样工作！

抱歉，如果这对你没用，但我觉得这值得一提。