
代码
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'] 有惊喜 |