当我使用 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 它工作正常，但只是给我一个警告信息：
警告属性主题无效（kafka.utils.verifiableproperties）
1条答案
按热度按时间t1rydlwq1#
你用的是什么版本的Kafka？
pykafka目前只支持0.8.2，不支持0.9.0。您可能希望改用restapi。在此处了解有关rest api的更多信息：
http://docs.confluent.io/2.0.0/kafka-rest/docs/index.html