我已经记录了 24 小时在 kafka 上发布的消息（从午夜到午夜）。大约有 120 万条消息。
现在，出于测试目的，我想使用这些日志来“重播”消息（即，从午夜开始，阅读日志并在最初发送时重新发布每条消息）。
是否有执行此操作的工具或库（最好是 Java 或 Scala）？
问问题
448 次
1 回答
2
您可以编写类似使用自 Kafka 0.10 以来可用的offsetsForTimes之类的东西，倒回到给定的偏移量，然后消费和生产记录直到下一个午夜
于 2017-10-23T20:27:02.160 回答