python读取Kafka实例

yipeiwu_com5年前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图像处理库Pillow常用使用方法

 PIL(Python Image Library)是python的第三方图像处理库,但是由于其强大的功能与众多的使用人数,几乎已经被认为是python官方图像处理库了。 其官...

通过pykafka接收Kafka消息队列的方法

没有Kafka环境,所以也没有进行验证。感觉今后应该能用到,所以借抄在此,备查。 pykafka使用示例,自动消费最新消息,不重复消费: # -* coding:utf8 *- fr...

python BeautifulSoup设置页面编码的方法

在用BeautifulSoup进行抓取页面的时候,会各种各样的编码错误。 可以通过在beautifulsoup中指定字符编码,解决问题。 复制代码 代码如下: import urllib...

python引入导入自定义模块和外部文件的实例

项目中想使用以前的代码,或者什么样的需求致使你需要导入外部的包 如果是web 下,比如说django ,那么你新建一个app,把你需要导入的说用东东,都写到这个app中,然后在setti...

Python实现向QQ群成员自动发邮件的方法

本文实例讲述了Python实现向QQ群成员自动发邮件的方法。分享给大家供大家参考。具体实现方法如下: 原理: 我们需要先获取QQ群中的所有成员并保存到一个txt文本中去,然后再由pyth...