Python测试Kafka集群(pykafka)实例

更新时间：2019年12月23日 09:10:37 作者：右介

今天小编就为大家分享一篇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(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'
client = KafkaClient(hosts = host) 
 
print client.topics 
 
# 消费者 
topic = client.topics['my-topic'] 
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)实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

简单了解python 邮件模块的使用方法
这篇文章主要介绍了简单了解python 邮件模块的使用方法,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-07-07
关于python爬虫的原理解析
这篇文章主要介绍了python爬虫原理,今天我们要向大家详细解说python爬虫原理，什么是python爬虫，python爬虫工作的基本流程是什么等内容，希望对这正在进行python爬虫学习的同学有所帮助
2023-07-07
python GUI库图形界面开发之PyQt5窗口背景与不规则窗口实例
这篇文章主要介绍了python GUI库图形界面开发之PyQt5窗口背景与不规则窗口实例,需要的朋友可以参考下
2020-02-02
python 读文件,然后转化为矩阵的实例
下面小编就为大家分享一篇python 读文件,然后转化为矩阵的实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-04-04
python实现公司年会抽奖程序
这篇文章主要为大家详细介绍了python实现公司年会抽奖程序，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2019-01-01
Python 实现简单的shell sed替换功能(实例讲解)
下面小编就为大家带来一篇Python 实现简单的shell sed替换功能(实例讲解)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-09-09
Python基础之函数原理与应用实例详解
这篇文章主要介绍了Python基础之函数原理与应用,结合具体实例形式详细分析了Python函数的定义、原理、参数、返回值、嵌套等相关概念与使用技巧,需要的朋友可以参考下
2020-01-01
python编写暴力破解zip文档程序的实例讲解
下面小编就为大家分享一篇python编写暴力破解zip文档程序的实例讲解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-04-04
Tensorflow 2.1完成对MPG回归预测详解
这篇文章主要为大家介绍了Tensorflow 2.1完成对MPG回归预测详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-11-11
docker django无法访问redis容器的解决方法
今天小编就为大家分享一篇docker django无法访问redis容器的解决方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2019-08-08