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