前言

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里面被消费