今天小编就为大家分享一篇Python测试Kafka集群(pykafka)实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

生产者代码： # -* coding:utf8 *- from pykafka import KafkaClient host = 'IP:9092, IP:9092, IP:9092' client = KafkaClient(hosts = host) print client.topics # 生产者 topicdocu = client.topics['my-topic'] producer = topicdocu.get_producer() for i in range(10