Lambda の自己管理 Kafka ESM でキュー消費に対応
- 要約
- 2026年11月2日の What's New は、自己管理の Apache Kafka イベントソースに Queue モードが追加されたと発表しました。対象は自分で動かすクラスターと Confluent Cloud などです。前提は share groups を有効にした Kafka 4.2 以降で、Queue モードはパーティションの順序を保ちません。既存マッピングが自動で切り替わるとは書かれていません。
- 何が変わったか
- 対象は自己管理 Kafka のイベントソースで、自分で動かすクラスターと Confluent Cloud などが含まれる
- Queue モードは、作成時に ConsumptionMode を Queue にした場合の動作である。未指定時の既定は Stream
- 前提は share groups を有効にしたクラスターで、開発者ガイドの利用条件は Apache Kafka 4.2 以降
- Queue モードはパーティション順序を保たない。各イベントポーラーの同時実行は最大 10
- 開発者ガイドは、Amazon MSK が現時点で Queue モードに非対応だと記載している
- 既存環境への影響
- What's New は、プロデューサー、トピック設定、関数コードを変えずに、並列度をパーティション数から切り離せると書いています。既存のコンシューマーグループ方式が、この発表だけで Queue に変わるとは書いていません。開発者ガイドは、ConsumptionMode を指定しなければ Stream であり、Queue は順序を保証しないと書いています。
- 利用可能リージョン
- 東京(ap-northeast-1)
- 未確認
- 大阪(ap-northeast-3)
- 未確認
What's New は、自己管理 Kafka のイベントソースが使えるすべての商用リージョンで利用できると記載しています。自己管理 Kafka ESM が東京・大阪にあるとは書かれておらず、Queue モードの開発者ガイドにも両リージョンの記載はありません。条件付きの文のため、未確認のままです。
- 対応が必要か
- 対応不要「対応不要」は、既存のイベントソースへの必須の移行がない、という意味です。Queue モードを使い始める設定まで不要、という意味ではありません。使う場合は、自己管理 Kafka で share groups を有効にし、イベントソースの作成時に ConsumptionMode を Queue にします。