© 1999-2048 dssz.net 粤ICP备11031372号
[其它] 通过pykafka接收Kafka消息队列的方法
说明:没有Kafka环境,所以也没有进行验证。感觉今后应该能用到,所以借抄在此,备查。 pykafka使用示例,自动消费最新消息,不重复消费: # -* coding:utf8 *- from pykafka import KafkaClient host = '192.168.200.38' client = KafkaClient(hosts="%s:9092" % host) print client.topics # 生产者 # topicdocu = client.topics['task<weixin_38705640> 上传 | 大小:38kb