カフカメッセージの削除ポリシーをどのように設定しますか?
Kafkaのメッセージ削除ポリシーは、以下のプロパティで構成することができます。
- retention.ms: このプロパティは、ログ内でメッセージを保持する時間を指定します。デフォルト値は7日です。必要に応じてこの値を調整して、メッセージの保持時間を設定することができます。
- cleanup.policy:この属性は削除ポリシーを指定します。選択できる値はいくつかあります:
- 削除:保持期限が切れた後、メッセージが削除されます。
- コンパクト: 有効期限が切れたメッセージは圧縮され(最新の更新が保持される)、保持されます。
- 削除と圧縮:メッセージは削除され、圧縮されます。
- min.cleanable.dirty.ratio:データクリーニング(削除または圧縮)を行う前に、最小の汚れデータの比率を指定する属性です。デフォルト値は0.5であり、汚れデータの比率が50%に達した時にのみデータクリーニング操作が実行されることを示します。
これらの属性は、Kafkaの設定ファイル(例えばserver.properties)で設定することができます。必要に応じてこれらの属性の値を変更し、Kafka Brokerを再起動して設定を有効にできます。