python读取Kafka实例
作者:技术那点事 时间:2023-10-22 17:22:58
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. 执行结果
来源:https://blog.csdn.net/laozhuxiao/article/details/78874994
标签:python,读取,Kafka
0
投稿
猜你喜欢
numpy np.newaxis 的实用分享
2023-01-21 06:06:25
javascript下兼容firefox选取textarea文本的代码
2013-08-30 02:05:16
Python with语句上下文管理器两种实现方法分析
2023-03-21 21:50:18
python实现猜拳游戏
2023-09-15 00:24:04
JavaScript正则表达式匹配 div style标签
2024-04-10 10:40:10
关于python中plt.hist参数的使用详解
2021-07-05 05:57:23
Django实现jquery select2带搜索的下拉框
2022-04-20 18:50:58
python 输入一个数n,求n个数求乘或求和的实例
2022-06-06 01:44:36
javascript之学会吝啬 精简代码
2024-04-19 09:52:21
关于Idea向GitHub push代码时一直重复提示输入用户名和密码的问题
2023-02-28 07:57:10
python写入并获取剪切板内容的实例
2023-08-03 10:44:04
python 获取页面表格数据存放到csv中的方法
2021-01-28 02:13:48
jupyter notebook 恢复误删单元格或者历史代码的实现
2022-03-03 16:13:45
javascript禁用Tab键脚本实例
2023-10-13 10:53:58
SQLServer中字符串左对齐或右对齐显示的sql语句
2012-06-06 19:36:45
docker上安装使用mysql镜像
2024-01-24 21:04:15
asp.net LINQ中数据库连接字符串的问题
2024-01-17 03:33:31
PyCharm Anaconda配置PyQt5开发环境及创建项目的教程详解
2022-03-12 07:15:47
10个很实用的js小脚本代码
2007-10-17 21:08:00
详解Vue用cmd创建项目
2024-05-21 10:16:38