这是一个创建于 3305 天前的主题，其中的信息可能已经有所发展或是发生改变。
代码
from pykafka import KakaClient client = KafkaClient( zookeeper_hosts='127.0.0.1:2181') print client, dir(client), client.brokers, client.cluster printclient.topics 输出
{'test': None, 'syslog-topic': None} 我在 shell 里面通过
>>bin/kafka-console-producer.sh --broker-list localhost:9092 --topic syslog-topic >>asdkasdjkasjd 输入了一些字符串 为什么 topics 字典里面还是 None
 | 1 QuinlanGgame OP 哎呀呀，新手跪求大神帮忙 |
 | 2 phttc 2016-12-08 09:10:01 +08:00 消息订阅啊。。。你客户端得去调用订阅。。。 |
| 3 QuinlanGgame OP @phttc 我代码里面获取到了这个 topics ，这个字典的 value 是个 none ，不应该是 Topic 对象么？是 Topic 对象的话，才可以去 consume 的吧？ |
 | 4 baocaixiong 2016-12-08 16:46:21 +08:00 print client.topics['test'] 有惊喜 |
Select Language