kafkaトピックのretention.msプロパティを変更すると古いデータが削除されます

Question

既存のトピックのretention.msプロパティを変更しようとしていますが、分析の結果、トピック内のすべての既存データが削除されます。

シナリオ： - 最初はトピック名が"topic1"で、保持時間は5分であり、いくつかのデータが含まれています。

ユースケース1 - それから私は、以下のコマンドを使用して、8分にretention.ms値を変更し、より高い期間 に保持を変更します -

bin/kafka-topics.sh --alter --zookeeper localhost:2181 
    --topic topic1 --config retention.ms=8 

しかし、それはそれからすべての私の古いデータを削除トピック。 その後、私はそのトピックにいくつかのデータを追加しました。

ユースケース2 - その後、私は、以下のコマンドを使用して、3分にretention.ms値を変更低く期間 に保持を変更します -

bin/kafka-topics.sh --alter --zookeeper localhost:2181 
    --topic topic1 --config retention.ms=3 

またそこからという以前のデータが削除されますトピック。

誰かが同じものの正確な動作を教えてください。

ヒントありがとうございます！

Answer 1

retention.msカフカのプロパティにはミリ秒かかります。したがって、保持期間をそれぞれ8ミリ秒と3ミリ秒に変更しています。保存期間を8分に設定する場合は、480000を指定する必要があります。