Kafka Streamsにおいて、同じキーを持つデータが異なるパーティションに存在する場合、Joinの前に実行される処理はどれか。

2026年3月8日

Joinの条件を満たすために、内部トピックを使用してデータを再分配（Repartition）し、キーを同じパーティションに集める。

トランザクションプロデューサーによって書かれたメッセージを、コミットされたもののみ読み取るためのコンシューマー設定はどれか。

ブローカーが正常にシャットダウンされる際に、リーダーシップを他のブローカーへ移譲する機能を何と呼ぶか。