Kafka：最初に公開された時点で24時間のメッセージを再発行

kafkaに公開されたメッセージは24時間（深夜から深夜まで）記録されています。約120万件のメッセージがあります。Kafka：最初に公開された時点で24時間のメッセージを再発行

テスト目的で、これらのログを使用してメッセージを再生します（つまり、深夜に開始し、ログを読み取り、最初に送信された時点で各メッセージを再公開します）。

これにはツールやライブラリ（理想的にはJavaやScala）がありますか？

2017-10-23 david

あなたは与えられたオフセットに巻き戻し、その後、次の深夜までのレコードを生成&を消費し、カフカ0.10以降で使用可能ですoffsetsForTimesを使用してのようなものを書くことができ

2017-10-23 20:27:02

答えて