通過pykafka接收Kafka消息隊列的方法
更新時間：2018年12月27日 11:29:45 作者：BabyFish13
今天小編就為大家分享一篇通過pykafka接收Kafka消息隊列的方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
沒有Kafka環(huán)境，所以也沒有進行驗證。感覺今后應(yīng)該能用到，所以借抄在此，備查。
pykafka使用示例，自動消費最新消息，不重復(fù)消費：
# -* coding:utf8 *-
from pykafka import KafkaClient
host = '192.168.200.38'
client = KafkaClient(hosts="%s:9092" % host)
print client.topics
# 生產(chǎn)者
# 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消息隊列的方法就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關(guān)文章
今天小編就為大家分享一篇Anaconda下安裝mysql-python的包實例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-06-06
看這個標題，有點匪夷所思嗎？為什么for是難以想象的呢？因為在python中，它的確是很常用而且很強悍，強悍到以至于另外一個被稱之為迭代的東西，在python中就有點相形見絀了。在別的語言中，for的地位從來沒有如同python中這么高的。2014-10-10
PyTorch快速搭建神經(jīng)網(wǎng)絡(luò)及其保存提取方法詳解
本篇文章主要介紹了PyTorch快速搭建神經(jīng)網(wǎng)絡(luò)及其保存提取方法詳解，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-04-04
這篇文章主要介紹了Python實現(xiàn)PS濾鏡功能之波浪特效,結(jié)合實例形式分析了Python實現(xiàn)PS濾鏡波浪特效的原理與相關(guān)操作技巧,需要的朋友可以參考下2018-01-01
Python判斷一個數(shù)是否為質(zhì)數(shù)的3種方法(超詳細)
一個大于1的自然數(shù),除了1和它本身外,不能被其他自然數(shù)（質(zhì)數(shù)）整除（2, 3, 5, 7等）,換句話說就是該數(shù)除了1和它本身以外不再有其他的因數(shù),下面這篇文章主要給大家介紹了關(guān)于利用Python判斷一個數(shù)是否為質(zhì)數(shù)的3種方法,需要的朋友可以參考下2024-09-09
python 利用pandas將arff文件轉(zhuǎn)csv文件的方法
今天小編就為大家分享一篇python 利用pandas將arff文件轉(zhuǎn)csv文件的方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2019-02-02
python 實現(xiàn)調(diào)用子文件下的模塊方法
今天小編就為大家分享一篇python 實現(xiàn)調(diào)用子文件下的模塊方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-12-12
這篇文章主要介紹了python集合,實例分析了Python中返回一個返回值與多個返回值的方法,需要的朋友可以參考下2021-10-10
新手學(xué)習(xí)Python2和Python3中print不同的用法
在本篇文章里小編給大家分享的是關(guān)于Python2和Python3中print不同的用法，有興趣的朋友們可以學(xué)習(xí)下。2020-06-06
Python Sql數(shù)據(jù)庫增刪改查操作簡單封裝
這篇文章主要為大家介紹了Python Sql數(shù)據(jù)庫增刪改查操作簡單封裝，感興趣的小伙伴們可以參考一下2016-04-04