当我使用 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