python讀取Kafka實例

更新時間：2019年12月23日 09:46:05 作者：技術(shù)那點事

今天小編就為大家分享一篇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)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

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