我如何从Kafka-python的消费者端获取最近'n‘分钟内的数据(消息)

from kafka import KafkaConsumer
from datetime import datetime, timedelta

consumer = KafkaConsumer(
    'topic_name',  # 替换为你要消费的Kafka主题名称
    bootstrap_servers='kafka_servers',  # 替换为Kafka集群的服务器地址
    group_id='consumer_group_id',  # 替换为消费者组的唯一标识符
    enable_auto_commit=False,  # 禁用自动提交偏移量
    auto_offset_reset='earliest'  # 设置偏移量重置策略为最早
)

end_time = datetime.now()  # 当前时间
start_time = end_time - timedelta(minutes=n)  # n分钟前的时间

consumer.seek_to_beginning()

for message in consumer:
    timestamp = datetime.fromtimestamp(message.timestamp / 1000)  # 将消息的时间戳转换为datetime对象
    if start_time <= timestamp <= end_time:
        print(message.value)  # 处理消息，这里只是简单地打印消息的值
    elif timestamp > end_time:
        break  # 如果消息的时间戳超过了结束时间，则结束迭代