python kafka怎么消费数据

使用Kafka-Python库来消费数据。首先需要安装Kafka-Python库：

pip install kafka-python

然后，按照以下步骤消费数据：

1. 创建KafkaConsumer对象并指定主题名称和Kafka服务器地址：

from kafka import KafkaConsumer

consumer = KafkaConsumer(
    'my_topic',
    bootstrap_servers=['localhost:9092']
)

2. 调用consumer对象的poll方法来获取消息：

for msg in consumer.poll(timeout_ms=5000):
    print(msg)

3. 处理消息：

for msg in consumer.poll(timeout_ms=5000):
    for record in msg.value:
        print(record)

完整代码示例：

from kafka import KafkaConsumer

consumer = KafkaConsumer(
    'my_topic',
    bootstrap_servers=['localhost:9092']
)

for msg in consumer.poll(timeout_ms=5000):
    for record in msg.value:
        print(record)

注意：如果需要消费指定分区的数据，可以在创建KafkaConsumer对象时指定partition参数。另外，还可以使用group_id参数来指定消费者组。