python讀取Kafka實(shí)例
更新時(shí)間：2019年12月23日 09:46:05 作者：技術(shù)那點(diǎn)事
今天小編就為大家分享一篇python讀取Kafka實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧
1. 新建.py文件
# pip install kafka-python
from kafka import KafkaConsumer
import setting
conf = setting.luyang_kafka_setting
consumer = KafkaConsumer(bootstrap_servers=conf['host'], group_id=conf['groupid'])
print('consumer start to consuming...')
consumer.subscribe((conf['topic'], ))
for message in consumer:
print(message.topic, message.offset, message.key, message.value, message.value, message.partition)
以上是kafka主要程序
2. Kafka配置文件setting.py
luyang_kafka_setting = {
'host':'0.0.0.0:9092',
'topic':'zcfTest',
'groupid':'luyang1'
}
配置如上
3. 執(zhí)行結(jié)果
以上這篇python讀取Kafka實(shí)例就是小編分享給大家的全部內(nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要為大家介紹了python 賦值語句和基本輸入輸出，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2021-12-12
Python程序設(shè)計(jì)入門(1)基本語法簡介
Python是當(dāng)今日趨流行的一種腳本語言，它比Java更簡單，比php更強(qiáng)大，并且還適用于做桌面應(yīng)用的開發(fā)，這篇文章主要介紹了Python基本語法,需要的朋友可以參考下2014-06-06
Python入門...2007-02-02
教你用Type Hint提高Python程序開發(fā)效率
本文通過介紹和實(shí)例教大家如何利用Type Hint來提升Python程序開發(fā)效率，對(duì)大家使用python開發(fā)很有幫助，有需要的參考學(xué)習(xí)。2016-08-08
這篇文章主要介紹了Python編寫簡單的HTML頁面合并腳本的相關(guān)資料,需要的朋友可以參考下2016-07-07
Python實(shí)現(xiàn)自動(dòng)批量修改文件名稱
這篇文章主要為大家詳細(xì)介紹了如何基于Python語言，實(shí)現(xiàn)按照一定命名規(guī)則批量修改多個(gè)文件的文件名的效果，文中的示例代講解詳細(xì)，感興趣的可以了解一下2023-01-01
大家好，本篇文章主要講的是關(guān)于python的對(duì)象序列化介紹，感興趣的同學(xué)趕快來看一看吧，對(duì)你有幫助的話記得收藏一下2022-01-01
構(gòu)建Python包的五個(gè)簡單準(zhǔn)則簡介
這篇文章主要介紹了構(gòu)建Python包的五個(gè)簡單準(zhǔn)則簡介,在Github開源合作日趨主流的今天,健壯的Python包的構(gòu)建成為開發(fā)者必須要考慮到的問題,本文提出了五項(xiàng)建議,需要的朋友可以參考下2015-06-06
Python實(shí)現(xiàn)獲取亂序列表排序后的新下標(biāo)的示例
本文主要介紹了Python實(shí)現(xiàn)獲取亂序列表排序后的新下標(biāo)的示例，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04
python 計(jì)算數(shù)組中每個(gè)數(shù)字出現(xiàn)多少次--“Bucket”桶的思想
這篇文章主要介紹了python 計(jì)算數(shù)組中每個(gè)數(shù)字出現(xiàn)多少次--“Bucket”桶的思想,需要的朋友可以參考下2017-12-12