python讀取Kafka實例
更新時間：2019年12月23日 09:46:05 作者：技術那點事
今天小編就為大家分享一篇python讀取Kafka實例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
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實例就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關文章
這篇文章主要為大家介紹了python 賦值語句和基本輸入輸出，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2021-12-12
Python是當今日趨流行的一種腳本語言，它比Java更簡單，比php更強大，并且還適用于做桌面應用的開發(fā)，這篇文章主要介紹了Python基本語法,需要的朋友可以參考下2014-06-06
Python入門...2007-02-02
教你用Type Hint提高Python程序開發(fā)效率
本文通過介紹和實例教大家如何利用Type Hint來提升Python程序開發(fā)效率，對大家使用python開發(fā)很有幫助，有需要的參考學習。2016-08-08
這篇文章主要介紹了Python編寫簡單的HTML頁面合并腳本的相關資料,需要的朋友可以參考下2016-07-07
這篇文章主要為大家詳細介紹了如何基于Python語言，實現(xiàn)按照一定命名規(guī)則批量修改多個文件的文件名的效果，文中的示例代講解詳細，感興趣的可以了解一下2023-01-01
大家好，本篇文章主要講的是關于python的對象序列化介紹，感興趣的同學趕快來看一看吧，對你有幫助的話記得收藏一下2022-01-01
這篇文章主要介紹了構(gòu)建Python包的五個簡單準則簡介,在Github開源合作日趨主流的今天,健壯的Python包的構(gòu)建成為開發(fā)者必須要考慮到的問題,本文提出了五項建議,需要的朋友可以參考下2015-06-06
Python實現(xiàn)獲取亂序列表排序后的新下標的示例
本文主要介紹了Python實現(xiàn)獲取亂序列表排序后的新下標的示例，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-04-04
python 計算數(shù)組中每個數(shù)字出現(xiàn)多少次--“Bucket”桶的思想
這篇文章主要介紹了python 計算數(shù)組中每個數(shù)字出現(xiàn)多少次--“Bucket”桶的思想,需要的朋友可以參考下2017-12-12