python kafka消费固定分区数据

要消费 Kafka 的固定分区数据，可以使用 Kafka 的 Python 客户端库 `kafka-python`。首先，需要创建一个 Kafka 消费者对象，指定要消费的主题和分区，例如：

from kafka import KafkaConsumer

consumer = KafkaConsumer(
    'my_topic',
    bootstrap_servers=['my_kafka_server'],
    partition_assignment=[0]  # 消费第 0 分区的数据
)

然后，可以使用 `consumer` 对象的 `poll()` 方法来轮询消息。这个方法会返回一个消息列表，每个消息都包含主题、分区、偏移量和消息体。例如：

for msg in consumer.poll():
    print(msg.topic, msg.partition, msg.offset, msg.value)

在消费完消息后，记得关闭消费者对象：

consumer.close()