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

kcugc4gi  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(480)

我在Kafka上发表了24小时的信息(从午夜到午夜)。大约有120万条信息。
现在,出于测试目的,我想使用这些日志来“重放”消息(即,从午夜开始,读取日志并在最初发送时重新发布每条消息)。
有没有一个工具或库(最好是java或scala)可以做到这一点?

jhkqcmku

jhkqcmku1#

你可以写一些东西,比如使用Kafka0.10以来可用的offsetsfortimes,回放到给定的偏移量,然后消费和生产记录,直到下一个午夜

相关问题