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编程中,文件操作是连接程序与外部存储的桥梁,本文将从基础读写讲起,逐步深入到高效处理、异常管理、二进制操作等高级场景,希望对大家有所帮助2025-10-10
在本篇文章里小编给各位分享的是关于python中的线程池用法及实例内容，需要的朋友们可以参考下。2020-05-05
这篇文章主要介绍了Python序列化与反序列化pickle用法实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-11-11
浅谈Python的自省Introspection和反射机制Reflection
这篇文章主要介绍了浅谈Python的自省Introspection和反射机制Reflection,反射就是通过字符串的形式去对象(模块)中操作(查找/获取/删除/添加)成员,一种基于字符串的事件驱动,需要的朋友可以参考下2023-08-08
python3的一个天坑问题及解决方法:报错UnicodeDecodeError: ‘utf-8‘
在调试程序发现python3的一个天坑问题:报错UnicodeDecodeError: ‘utf-8‘ codec can‘t decode byte 0xa3 in position 59: invalid,特此曝光,为众位开发朋友提个醒2023-09-09
详细介绍pandas的DataFrame的append方法使用
这篇文章主要介绍了详细介绍pandas的DataFrame的append方法使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-07-07
基于tf.shape(tensor)和tensor.shape()的区别说明
这篇文章主要介绍了基于tf.shape(tensor)和tensor.shape()的区别说明，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-06-06
这篇文章主要介绍了Django框架中间件定义与使用方法,结合具体案例形式分析了Django框架中间件相关定义、原理、使用方法及操作注意事项,需要的朋友可以参考下2019-11-11
python的赋值操作有几种类型，下面我们分别给大家说下，需要的朋友可以参考下2013-03-03
折线图是一种用于可视化数据变化趋势的图表，它可以用于表示任何数值随着时间或类别的变化，本文主要介绍了如何利用Matplotlib实现折线图的绘制，感兴趣的可以了解下2023-08-08
最新评论