python读取Kafka实例

yipeiwu_com6年前Python基础

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. 执行结果

以上这篇python读取Kafka实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持【听图阁-专注于Python设计】。

相关文章

python实现用类读取文件数据并计算矩形面积

python实现用类读取文件数据并计算矩形面积

1.创建一个类Rectangle,已知a、b求面积,求三角形的面积 2.结合题目一,从题目一文件中读取数据,并采用类的方法,将计算的结果写在另一个文档中。 (1)利用类进行计算一个矩形的...

Linux CentOS Python开发环境搭建教程

CentOS安装Python 1.CentOS已经自带安装了2.x版本,先尝试python命令检查已安装的版本.如果你使用rpm、yum或deb命令安装过,请使用相对命令查询。 2.复制...

python利用datetime模块计算时间差

今天写了点东西,要计算时间差,我记得去年写过,于是今天再次mark一下,以免自己忘记 In [27]: from datetime import datetime In [28]:...

OPENCV去除小连通区域,去除孔洞的实例讲解

OPENCV去除小连通区域,去除孔洞的实例讲解

一、对于二值图,0代表黑色,255代表白色。去除小连通区域与孔洞,小连通区域用8邻域,孔洞用4邻域。 函数名字为:void RemoveSmallRegion(Mat &Src, Ma...

Python正则捕获操作示例

本文实例讲述了Python正则捕获操作。分享给大家供大家参考,具体如下: 目的: 给表达式 '10+6/5-4*2' 中每个运算符左右都加一个空格字符,变成:'10 + 6 / 5 -...