实现数据流连接至Kafka在Python生态系统中
发布时间
阅读量：
阅读量
安装步骤与配置
pip install kafka
使用场景与应用分析
依次开启zookeeper服务以及一个broker节点
$ bin/zookeeper-server-start.sh config/zookeeper.properties
$ bin/kafka-server-start.sh config/server.properties
执行以下Python脚本以生成消息
from kafka import KafkaProducer
# 创建生产者
producer = KafkaProducer(bootstrap_servers='127.0.0.1:9092')
for _ in range(3):
# 指定topic发送bytes类型的数据
producer.send('my_topic',b'Hello kafka')
producer.send('my_topic',b'Hello kafka')
AI写代码python
运行执行消费者接收数据信息
$ bin/kafka-con全部评论 (0)
还没有任何评论哟~