Python Package

kafka-python

2022-12-08

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

安装

1
pip install kafka-python

使用

1
from kafka import KafkaConsumer
2

3
consumer = KafkaConsumer(bootstrap_servers='localhost:9092',
4
                         auto_offset_reset='earliest',
5
                         consumer_timeout_ms=1000)
6

7
consumer.subscribe(['test'])
8

9
for message in consumer:
10
    print(message)

参考

kafka-python