はい。ApsaraMQ for Kafka では、オープンソース版 2.2.0 以降を実行しているインスタンスで、コンパクトクリーンアップポリシーがサポートされています。
コンパクションの機能
デフォルトでは、Kafka は delete クリーンアップポリシーを使用します:メッセージは保持期間またはサイズ制限に達すると削除されます。compact クリーンアップポリシーは異なる動作をし、各メッセージキーに対して最新の値のみを保持し、それより古い値は破棄します。
これは、レコードの完全な履歴ではなく、現在の状態のみが必要な場合に有効です。主な利用シーンは以下のとおりです:
データベース変更キャプチャ — 各データベース行の更新を記録したコンパクション済みの変更ログを維持し、各行の最新バージョンのみを保持します。
構成またはメタデータストレージ — アプリケーションの構成をキーと値のペアとして保存し、最も新しい設定のみを有効とします。
セッション状態管理 — 期限切れのエントリを蓄積することなく、ユーザーまたはデバイスごとの最新のセッション状態を追跡します。
バージョン要件
コンパクトクリーンアップポリシーを利用するには、オープンソース版 2.2.0 以降が必要です。ご利用のインスタンスがそれより前のバージョンを実行している場合は、まずアップグレードを行ってください。手順については、「インスタンスのメジャーバージョンをアップグレードする」をご参照ください。