python读取Kafka实例
作者：技术那点事 发布时间：2023-10-22 17:22:58
标签：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. 执行结果
来源：https://blog.csdn.net/laozhuxiao/article/details/78874994
0
投稿猜你喜欢
- 本文实例分析了php5.4传引用时报错问题。分享给大家供大家参考，具体如下：php5.3系列版本以及以前版本，传引用没有什么问题，升级到ph
- 利用XMLHTTP无刷新自动实时更新数据，2秒自动刷新一次,2秒取得一次数据.demo.htm 前台显示<script la
- 索引是提高数据查询最有效的方法，也是最难全面掌握的技术，因为正确的索引可能使效率提高10000倍，而无效的索引可能是浪费了数据库空间，甚至大
- 通过视图来访问数据，其优点是非常明显的。如可以起到数据保密、保证数据的逻辑独立性、简化查询操作等等。但是，话说回来，SQL Server数据
- 以前写过一个刷校内网的人气的工具，Java的(以后再也不行Java程序了)，里面用到了验证码识别，那段代码不是我自己写的:-) 校内的验证是
安装pillow(python的图形界面库)第一种方法在Dos界面输入pip install pillow(但是不知为何总是失败)；搞了好几- 放到公用调用文件（如conn数据库链接文件），对所有GET或POST的数据进行过滤特殊字符串，以实现简单有效的SQL注入过滤Function
- 最近在这找了好久的js菜单,都没找到满意的,今天找了个,觉得不错,最重要的是简单,希望大家可以参照一下先看看效果图吧:代码特点：js+css
- 到现在为止，你只学习了如何根据特定的条件从表中取出一条或多条记录。但是，假如你想对一个表中的记录进行数据统计。例如，如果你想统计存储在表中的
- 优秀的Stoyan Stefanov在他的新书中（《Javascript Patterns》）介绍了很多编写高质量代码的技巧，比如避免使用全
- 作者：Henny Swan / co-lead of WaSP ILG译者：JunChen / member of WaSP ILG原文：h
- 在MySQL数据库中导出整个数据库：1.导出整个数据库mysqldump -u 用户名 -p 数据库名 > 导出的文件名mysqldu
- 前言当我们运行测试函数时，我们希望确保测试函数在运行结束后，可以自己清理掉对环境的影响。这样的话，它们就不会干扰任何其他的测试函数，更不会日
- DesktopNexus 是我最喜爱的一个壁纸下载网站，上面有许多高质量的壁纸，几乎每天必上， 每月也必会坚持分享我这个月来收集的壁纸但是
- 装饰器简介：装饰器(decorator)是一种高级Python语法。装饰器可以对一个函数、方法或者类进行加工。在Python中，我们有多种方
- 数字函数 ABS():求绝对值。 CEILING():舍入到最大整数。 FLOOR():舍入到最小整数。 ROUND():四舍五入 ROUN
- 对url进行编码在服务器端我们可以使用asp中的server.urlencode，很方便实现。如：<％ ss="asp之家欢
- 代码如下:CREATE TABLE #tmptb(tbname sysname,tbrows int ,tbREserved varchar
- nii.gz格式是医学图像常用的压缩格式，python中可用nibabel和sitk来读取保存。使用nibabel由于使用nibabel图像
- Python 中的 timeit 模块可以用来测试一段代码的执行耗时，如一个变量赋值语句的执行时间，一个函数的运行时间等。timeit 模块
