通過(guò)pykafka接收Kafka消息隊(duì)列的方法
更新時(shí)間：2018年12月27日 11:29:45 作者：BabyFish13
今天小編就為大家分享一篇通過(guò)pykafka接收Kafka消息隊(duì)列的方法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
沒(méi)有Kafka環(huán)境，所以也沒(méi)有進(jìn)行驗(yàn)證。感覺(jué)今后應(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
以上這篇通過(guò)pykafka接收Kafka消息隊(duì)列的方法就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
Python如何用pip命令升級(jí)所有可以升級(jí)的(過(guò)時(shí)的)包
這篇文章主要介紹了Python如何用pip命令升級(jí)所有可以升級(jí)的(過(guò)時(shí)的)包,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-03-03
python 把數(shù)據(jù) json格式輸出的實(shí)例代碼
下面小編就為大家?guī)?lái)一篇python 把數(shù)據(jù) json格式輸出的實(shí)例代碼。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2016-10-10
Python實(shí)現(xiàn)讀取目錄所有文件的文件名并保存到txt文件代碼
這篇文章主要介紹了Python實(shí)現(xiàn)讀取目錄所有文件的文件名并保存到txt文件代碼,本文分別使用os.listdir和os.walk實(shí)現(xiàn)給出兩段實(shí)現(xiàn)代碼,需要的朋友可以參考下2014-11-11
這篇文章主要為大家介紹了Python異步之迭代器如何使用示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-03-03
如何對(duì)Python編譯PyInstaller打包生成的exe文件進(jìn)行反編譯生成pyc、py源代碼文件
很多開(kāi)發(fā)者沒(méi)有發(fā)布源程序代碼,而是將代碼封裝為exe可執(zhí)行文件,這樣不僅更有利于程序傳播,下面這篇文章主要介紹了如何對(duì)Python編譯PyInstaller打包生成的exe文件進(jìn)行反編譯生成pyc、py源代碼文件的相關(guān)資料,需要的朋友可以參考下2023-01-01
Python獲取網(wǎng)頁(yè)數(shù)據(jù)詳解流程
讀萬(wàn)卷書(shū)不如行萬(wàn)里路，只學(xué)書(shū)上的理論是遠(yuǎn)遠(yuǎn)不夠的，只有在實(shí)戰(zhàn)中才能獲得能力的提升，本篇文章手把手帶你用Python來(lái)獲取網(wǎng)頁(yè)的數(shù)據(jù)，主要應(yīng)用了Requests庫(kù),大家可以在過(guò)程中查缺補(bǔ)漏，提升水平2021-10-10
這篇文章主要為大家詳細(xì)介紹了python hook監(jiān)聽(tīng)事件的相關(guān)資料，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2018-10-10
Python檢查圖片是否損壞及圖片類型是否正確過(guò)程詳解
這篇文章主要介紹了Python檢查圖片是否損壞及圖片類型是否正確過(guò)程詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-09-09
OpenCV MediaPipe實(shí)現(xiàn)顏值打分功能
這篇文章主要介紹了通過(guò)OpenCV MediaPipe實(shí)現(xiàn)攝像頭實(shí)時(shí)檢測(cè)顏值打分功能，文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)Python有一定的幫助，感興趣的可以了解一下2021-12-12
解決Jupyter無(wú)法導(dǎo)入已安裝的 module問(wèn)題
這篇文章主要介紹了解決Jupyter無(wú)法導(dǎo)入已安裝的 module問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-04-04