欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

通過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)文章

  • Python如何用pip命令升級所有可以升級的(過時的)包

    Python如何用pip命令升級所有可以升級的(過時的)包

    這篇文章主要介紹了Python如何用pip命令升級所有可以升級的(過時的)包,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-03-03
  • python 把數(shù)據(jù) json格式輸出的實例代碼

    python 把數(shù)據(jù) json格式輸出的實例代碼

    下面小編就為大家?guī)硪黄猵ython 把數(shù)據(jù) json格式輸出的實例代碼。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2016-10-10
  • Python實現(xiàn)讀取目錄所有文件的文件名并保存到txt文件代碼

    Python實現(xiàn)讀取目錄所有文件的文件名并保存到txt文件代碼

    這篇文章主要介紹了Python實現(xiàn)讀取目錄所有文件的文件名并保存到txt文件代碼,本文分別使用os.listdir和os.walk實現(xiàn)給出兩段實現(xiàn)代碼,需要的朋友可以參考下
    2014-11-11
  • Python異步之迭代器如何使用詳解

    Python異步之迭代器如何使用詳解

    這篇文章主要為大家介紹了Python異步之迭代器如何使用示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-03-03
  • 如何對Python編譯PyInstaller打包生成的exe文件進行反編譯生成pyc、py源代碼文件

    如何對Python編譯PyInstaller打包生成的exe文件進行反編譯生成pyc、py源代碼文件

    很多開發(fā)者沒有發(fā)布源程序代碼,而是將代碼封裝為exe可執(zhí)行文件,這樣不僅更有利于程序傳播,下面這篇文章主要介紹了如何對Python編譯PyInstaller打包生成的exe文件進行反編譯生成pyc、py源代碼文件的相關(guān)資料,需要的朋友可以參考下
    2023-01-01
  • Python獲取網(wǎng)頁數(shù)據(jù)詳解流程

    Python獲取網(wǎng)頁數(shù)據(jù)詳解流程

    讀萬卷書不如行萬里路,只學(xué)書上的理論是遠遠不夠的,只有在實戰(zhàn)中才能獲得能力的提升,本篇文章手把手帶你用Python來獲取網(wǎng)頁的數(shù)據(jù),主要應(yīng)用了Requests庫,大家可以在過程中查缺補漏,提升水平
    2021-10-10
  • python hook監(jiān)聽事件詳解

    python hook監(jiān)聽事件詳解

    這篇文章主要為大家詳細介紹了python hook監(jiān)聽事件的相關(guān)資料,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2018-10-10
  • Python檢查圖片是否損壞及圖片類型是否正確過程詳解

    Python檢查圖片是否損壞及圖片類型是否正確過程詳解

    這篇文章主要介紹了Python檢查圖片是否損壞及圖片類型是否正確過程詳解,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2019-09-09
  • OpenCV MediaPipe實現(xiàn)顏值打分功能

    OpenCV MediaPipe實現(xiàn)顏值打分功能

    這篇文章主要介紹了通過OpenCV MediaPipe實現(xiàn)攝像頭實時檢測顏值打分功能,文中的示例代碼講解詳細,對我們學(xué)習(xí)Python有一定的幫助,感興趣的可以了解一下
    2021-12-12
  • 解決Jupyter無法導(dǎo)入已安裝的 module問題

    解決Jupyter無法導(dǎo)入已安裝的 module問題

    這篇文章主要介紹了解決Jupyter無法導(dǎo)入已安裝的 module問題,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-04-04

最新評論