今天小编就为大家分享一篇通过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_pull']
# producer = topicdocu.get_producer()
# for i in range(4):
#   print i
#   producer.produce('test message ' + str(i ** 2))
# producer.stop()
 
# 消费者
topic = client.topics['task_push']
consumer = topic.get_simple_consumer(consumer_group='test', auto_commit_enable=True, consumer_id='test')
for message in consumer:
  if message is not None:
    print message.offset, message.value

以上这篇通过pykafka接收Kafka消息队列的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持爱安网。

最新资讯
商务部:2020年中国在线教育销售额同比增长逾140%

商务部:2020年中国在线

中国商务部22日公布的最新数据显示,受疫情影响,2020年中
无私桩新能源车主过冬:充电时间延长2倍 续航“里程焦虑”难破

无私桩新能源车主过冬

爱驰汽车相关负责人告诉记者:“以目前电池技术条件,冬季
腾讯获得13亿欧元贷款用以购买环球音乐股份

腾讯获得13亿欧元贷款

据报道,腾讯获得13亿欧元贷款用以购买环球音乐股份。
新交所与淡马锡合作推进资本市场数字资产基础设施建设

新交所与淡马锡合作推

新加坡交易所(“新交所”)22日宣布与淡马锡成立合资公司
新东方2021财年第二季度营收8.88亿美元 同比增长13%

新东方2021财年第二季

新东方今日发布了2021财年第二季度财报。财报显示,新东
中兴通讯:2020年全年净利润43.67亿元 同比下降15.18%

中兴通讯:2020年全年净

2020年度,中兴通讯归属于上市公司普通股股东的净利润43
最新文章
在pycharm中为项目导入anacodna环境的操作方法

在pycharm中为项目导

这篇文章主要介绍了在pycharm中为项目导入anacodna环
tensorflow的ckpt及pb模型持久化方式及转化详解

tensorflow的ckpt及pb

今天小编就为大家分享一篇tensorflow的ckpt及pb模型持
PyTorch笔记之scatter()函数的使用

PyTorch笔记之scatter

这篇文章主要介绍了PyTorch笔记之scatter()函数的使用
python3实现网页版raspberry pi(树莓派)小车控制

python3实现网页版ras

这篇文章主要为大家详细介绍了python3实现网页版raspb
完美解决pycharm导入自己写的py文件爆红问题

完美解决pycharm导入

今天小编就为大家分享一篇完美解决pycharm导入自己写
pycharm内无法import已安装的模块问题解决

pycharm内无法import

今天小编就为大家分享一篇pycharm内无法import已安装