python - 如何获取 Kafka-python 消费者端最后 'n' 分钟内的数据（消息）

Question

我有一个生产者以字典列表的形式发送消息。消费者阅读消息，但我无法获取在最后“n”分钟内到达的消息。任何帮助，将不胜感激。

标签： pythonapache-kafkakafka-python

Answer 1

有规定可以倒带特定的时间戳。为此，您需要在消费者中手动为主题分配分区，然后使用seek方法。