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