如何在kafka python的用户端的最后n分钟内获得数据(messags)

drkbr07n  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(269)

我有一个制作人以词典列表的形式发送消息。消费者阅读消息,但我无法获取在最后n分钟内到达的消息。任何帮助都将不胜感激。

eqoofvh9

eqoofvh91#

有回放特定时间戳的规定。为了做到这一点,您需要为使用者中的主题手动分配分区,然后使用 seek 方法。

相关问题