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