我在Kafka上发表了24小时的信息(从午夜到午夜)。大约有120万条信息。现在,出于测试目的,我想使用这些日志来“重放”消息(即,从午夜开始,读取日志并在最初发送时重新发布每条消息)。有没有一个工具或库(最好是java或scala)可以做到这一点?
jhkqcmku1#
你可以写一些东西,比如使用Kafka0.10以来可用的offsetsfortimes,回放到给定的偏移量,然后消费和生产记录,直到下一个午夜
1条答案
按热度按时间jhkqcmku1#
你可以写一些东西,比如使用Kafka0.10以来可用的offsetsfortimes,回放到给定的偏移量,然后消费和生产记录,直到下一个午夜