如何使用Python读写Kafka？

2023-09-08 08:47| 来源: 网络整理| 查看: 265

关于Kafka的第三篇文章，我们来讲讲如何使用Python读写Kafka。这一篇文章里面，我们要使用的一个第三方库叫做kafka-python。大家可以使用pip或者pipenv安装它。下面两种安装方案，任选其一即可。

python3 -m pip install kafka-python pipenv install kafka-python

如下图所示：

这篇文章，我们将会使用最短的代码来实现一个读、写Kafka的示例。

创建配置文件

由于生产者和消费者都需要连接Kafka，所以我单独写了一个配置文件config.py用来保存连接Kafka所需要的各个参数，而不是直接把这些参数Hard Code写在代码里面：

# config.py SERVER = '123.45.32.11:1234' USERNAME = 'kingname' PASSWORD = 'kingnameisgod' TOPIC = 'howtousekafka'

【本文地址】

今日新闻