前言
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里面被消费
领取专属 10元无门槛券
私享最新 技术干货