python 使用 kafka 系列问题 topics 为空

[QuinlanGgame]

代码

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

[QuinlanGgame]

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

[phttc]

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

[QuinlanGgame]

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

[baocaixiong]

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