Python测试Kafka集群(pykafka)实例

Python测试测试Kafka集群集群(pykafka)实例实例

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

一起跟随小编过来看看吧

生产者代码：生产者代码：

# -* coding:utf8 *-

from pykafka import KafkaClient

host = 'IP:9092, IP:9092, IP:9092'

producer = topicdocu.get_producer()

for i in range(100):

print i

producer.produce('test message ' + str(i ** 2))

producer.stop()

消费者代码：消费者代码：

# -* coding:utf8 *-

from pykafka import KafkaClient

host = 'IP:9092, IP:9092, IP:9092'

consumer = topic.get_simple_consumer(consumer_group='test', auto_commit_enable=True, auto_commit_interval_ms=1,

consumer_id='test')

for message in consumer:

if message is not None:

print message.offset, message.value

以上这篇Python测试Kafka集群(pykafka)实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支

持我们。