python讀取Kafka實(shí)例
更新時(shí)間：2019年12月23日 09:46:05 作者：技術(shù)那點(diǎn)事
今天小編就為大家分享一篇python讀取Kafka實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
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í)例就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
從基礎(chǔ)到高級(jí)詳解Python中文件操作的全攻略實(shí)戰(zhàn)指南
在Python編程中,文件操作是連接程序與外部存儲(chǔ)的橋梁,本文將從基礎(chǔ)讀寫講起,逐步深入到高效處理、異常管理、二進(jìn)制操作等高級(jí)場(chǎng)景,希望對(duì)大家有所幫助2025-10-10
在本篇文章里小編給各位分享的是關(guān)于python中的線程池用法及實(shí)例內(nèi)容，需要的朋友們可以參考下。2020-05-05
這篇文章主要介紹了Python序列化與反序列化pickle用法實(shí)例,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-11-11
淺談Python的自省Introspection和反射機(jī)制Reflection
這篇文章主要介紹了淺談Python的自省Introspection和反射機(jī)制Reflection,反射就是通過(guò)字符串的形式去對(duì)象(模塊)中操作(查找/獲取/刪除/添加)成員,一種基于字符串的事件驅(qū)動(dòng),需要的朋友可以參考下2023-08-08
python3的一個(gè)天坑問(wèn)題及解決方法:報(bào)錯(cuò)UnicodeDecodeError: ‘utf-8‘
在調(diào)試程序發(fā)現(xiàn)python3的一個(gè)天坑問(wèn)題:報(bào)錯(cuò)UnicodeDecodeError: ‘utf-8‘ codec can‘t decode byte 0xa3 in position 59: invalid,特此曝光,為眾位開(kāi)發(fā)朋友提個(gè)醒2023-09-09
詳細(xì)介紹pandas的DataFrame的append方法使用
這篇文章主要介紹了詳細(xì)介紹pandas的DataFrame的append方法使用，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-07-07
基于tf.shape(tensor)和tensor.shape()的區(qū)別說(shuō)明
這篇文章主要介紹了基于tf.shape(tensor)和tensor.shape()的區(qū)別說(shuō)明，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-06-06
這篇文章主要介紹了Django框架中間件定義與使用方法,結(jié)合具體案例形式分析了Django框架中間件相關(guān)定義、原理、使用方法及操作注意事項(xiàng),需要的朋友可以參考下2019-11-11
python的賦值操作有幾種類型，下面我們分別給大家說(shuō)下，需要的朋友可以參考下2013-03-03
Matplotlib實(shí)戰(zhàn)之折線圖繪制詳解
折線圖是一種用于可視化數(shù)據(jù)變化趨勢(shì)的圖表，它可以用于表示任何數(shù)值隨著時(shí)間或類別的變化，本文主要介紹了如何利用Matplotlib實(shí)現(xiàn)折線圖的繪制，感興趣的可以了解下2023-08-08