Python Package

kafka-python

2022-12-08

kafka-python 是一个 Kafka 的 [[Python]] 客户端库。

安装

Terminal window
pip install kafka-python

使用

from kafka import KafkaConsumer


consumer = KafkaConsumer(bootstrap_servers='localhost:9092',
                         auto_offset_reset='earliest',
                         consumer_timeout_ms=1000)


consumer.subscribe(['test'])


for message in consumer:
    print(message)

参考

# Python
# Package
# Kafka
# 消息队列