apache-kafka - pykafka 无法连接 kafka 代理

Question

当我使用通过以下代码pykafka连接集群时：kafka

from pykafka import KafkaClient
client = KafkaClient(hosts="10.0.0.101:9092")

我得到以下异常：

raise Exception('无法连接到代理来获取元数据。')

例外：无法连接到代理以获取元数据。

但是当我使用命令行时，例如：

kafka-console-producer --broker-list 10.0.0.101:9092 --topic userCND

它工作正常，但只是给我一个警告信息：

WARN 属性主题无效 (kafka.utils.VerifiableProperties)

score 2 · Accepted Answer

你用的是什么版本的卡夫卡？pykafka目前只支持0.8.2，不支持0.9.0。

您可能想改用 REST API。在此处了解有关 REST API 的更多信息：

1 回答 1