python读取Kafka实例
更新时间：2019年12月23日 09:46:05 作者：技术那点事
今天小编就为大家分享一篇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. 执行结果
以上这篇python读取Kafka实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了python中单下划线与双下划线的区别及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-09-09
python人工智能human learn绘图创建机器学习模型
这篇文章主要为大家介绍了python人工智能human learn绘图就可以创建机器学习模型的示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助2021-11-11
今天小编就为大家分享一篇Python之csv文件从MySQL数据库导入导出的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-06-06
python Sweetviz探索性数据可视化分析库使用特征详解
这篇文章主要为大家介绍了python Sweetviz探索性数据可视化分析库特征使用详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2024-01-01
这篇文章主要介绍了python实现ping的方法,以实例形式较为详细的分析了Python发送ICMP数据包实现ping功能的相关技巧,需要的朋友可以参考下2015-07-07
这篇文章主要为大家详细介绍了Python连接mysql数据库的正确姿势，如何使用Python连接mysql数据库，本文为大家揭晓，感兴趣的小伙伴们可以参考一下2016-02-02
今天小编就为大家分享一篇在python 中split()使用多符号分割的例子，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2019-07-07
这篇文章主要为大家详细介绍了python实现字符串加密成纯数字，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2019-03-03
这篇文章主要为大家介绍了python开发微信服务号消息推送示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-10-10
今天小编就为大家分享一篇python 在屏幕上逐字显示一行字的实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-12-12
最新评论