python 使用 kafka 系列问题 topics 为空

This topic created in 3456 days ago, the information mentioned may be changed or developed.

代码

from pykafka import KakaClient
client = KafkaClient(
zookeeper_hosts='127.0.0.1:2181')
print client, dir(client), client.brokers, client.cluster
print client.topics

输出

{'test': None, 'syslog-topic': None}

我在 shell 里面通过

>>bin/kafka-console-producer.sh --broker-list localhost:9092 --topic syslog-topic
>>asdkasdjkasjd

输入了一些字符串为什么 topics 字典里面还是 None

Client

none

topics

4 replies • 2016-12-08 16:46:21 +08:00

QuinlanGgame

Dec 7, 2016

哎呀呀，新手跪求大神帮忙

phttc

Dec 8, 2016

消息订阅啊。。。你客户端得去调用订阅。。。

QuinlanGgame

Dec 8, 2016

@phttc 我代码里面获取到了这个 topics ，这个字典的 value 是个 none ，不应该是 Topic 对象么？是 Topic 对象的话，才可以去 consume 的吧？

baocaixiong

Dec 8, 2016

print client.topics['test'] 有惊喜