今天小编就为大家分享一篇通过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