apache-kafka - 尝试连接到 Kafka 时出现 No Brokers Available 错误

Question

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

我的连接选项非常简单和默认:

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

当我手动设置 听众 Kafka 的 server.properties 文件中的选项，如:

listeners=PLAINTEXT://localhost:9092

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

否 广告。听众或其他已弃用的广告选项有助于解决问题。因此，唯一有效的配置状态是没有监听器的状态。这当然是 Not Acceptable ，因为我们需要以某种方式设置本地集群。

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

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

一切都像以前一样!

抱歉，如果这对您不起作用，但我认为值得一提。