Python Kafka 消费者代码示例 - 从Kafka获取数据

Python Kafka 消费者代码示例 - 从Kafka获取数据

以下是一个简单的Python代码示例，用于从Kafka消费数据。在运行之前，请确保您已经安装了Kafka Python库。

from kafka import KafkaConsumer

# 创建一个Kafka消费者对象
consumer = KafkaConsumer(
    '{'topic_name'}',  # 填写你的topic名称
    bootstrap_servers=['{'bootstrap_servers'}'],  # 填写你的Kafka服务器地址
    auto_offset_reset='earliest',  # 从最早的offset开始消费
    enable_auto_commit=True,  # 启用自动提交offset
    group_id='{'group_id'}'  # 填写你的消费者组ID
)

# 循环消费消息
for message in consumer:
    # 打印消息的key和value
    print(f'Key: {message.key}, Value: {message.value}')

上面的代码可以从指定的Kafka topic中消费数据，并打印每个消息的key和value。

请记住将'{'topic_name'}'、'{'bootstrap_servers'}'和'{'group_id'}'替换为你自己的值。