Kafka:在最初发布消息时重新发布 24 小时消息

Question

我已经记录了在kafka上发布的24小时消息（从午夜到午夜）。大约有 120 万条消息。

现在，出于测试目的，我想使用这些日志来"重播"消息（即，从午夜开始，读取日志并在最初发送时重新发布每条消息）。

是否有工具或库（最好是Java或Scala）可以做到这一点？

Answer 1

你可以写一些东西，比如使用自Kafka 0.10以来可用的偏移量，倒带到给定的偏移量，然后消费和制作记录直到下一个午夜