首页
学习
活动
专区
工具
TVP
发布

Python3-测试生产、消费kafka

前言

python3操作kafka需要安装kafka模块。

可以通过pip直接安装

pip install kafka

脚本

导入模块

from kafka import KafkaProducer

from kafka import KafkaConsumer

from kafka.errors import KafkaError

import json

import time

生产者类

消费者类

主函数进行测试:

生产者:

消费者:

具体脚本可以在码云上面找到,我上传的脚本

https://gitee.com/jalright/scriptstodo/blob/master/kafka/producer.py

https://gitee.com/jalright/scriptstodo/blob/master/kafka/cunsumer.py

使用

分别运行两个脚本,可以看到product的脚本生产的数据,可以在consumer里面被消费

  • 发表于:
  • 原文链接http://kuaibao.qq.com/s/20171230A0JO7X00?refer=cp_1026
  • 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 cloudcommunity@tencent.com 删除。

扫码

添加站长 进交流群

领取专属 10元无门槛券

私享最新 技术干货

扫码加入开发者社群
领券