すべてのプロダクト
Search
ドキュメントセンター

ApsaraMQ for Kafka:トピック トラフィックのリバランス

最終更新日:Jan 11, 2025

ApsaraMQ for Kafka インスタンスのトラフィック仕様をアップグレードすると、対応するクラスターがスケールアウトされる場合があります。クラスターがスケールアウトされた後、スケールアウトされたクラスターのブローカー全体にトラフィックを均等に分散させるために、トピック トラフィックをリバランスする必要があります。そうでない場合、元のトピック トラフィックは、スケールアウト前のクラスター内のブローカーに引き続き分散されます。元のトピックは、スケールアウト前に購入された最大トラフィックの対象となります。新しいトピックは、スケールアウト前に購入された最大トラフィックの対象となりません。

前提条件

ApsaraMQ for Kafka インスタンスが [実行中 (リバランス待機中)] 状態です。

説明

ApsaraMQ for Kafka インスタンスのトラフィック仕様をアップグレードする方法と、クラスターのスケールアウトをトリガーするルールについては、インスタンス構成のアップグレード をご参照ください。

注意事項

ApsaraMQ for Kafka インスタンスが [実行中 (リバランス待機中)] 状態の場合、このインスタンスを使用してメッセージを送受信できます。ただし、このインスタンスでは、トピックや グループ などのリソースを作成することはできません。リソースを作成するには、トピック トラフィックがリバランスされるまで待つ必要があります。トピック トラフィックをリバランスしないことを選択することもできます。

トラフィック リバランス方法

トラフィック リバランス方法

動作メカニズム

影響

シナリオ

期間

パーティションの追加

クラスターがスケールアウトされた後、システムは元のブローカーのすべてのトピックについて、新しいブローカーにパーティションを追加します。

  • パーティション内の新しいメッセージの順序が正しくありません。

  • パーティションの数が変更されます。クライアントが新しいパーティションを自動的に検出できない場合は、クライアントを再起動するか、クライアント コードを変更する必要があります。これは、抽出、転送、ロード (ETL) が実行されるシナリオ、または特定のパーティションにメッセージを送信したり、特定のパーティションからメッセージを消費したりするシナリオで発生する可能性があります。

  • パーティションの順序は不要です。

  • メッセージの送信先パーティションは指定されていません。

  • 選択された消費モードはサブスクリプションです。

数秒以内。

パーティションの移行 (推奨)

  • ローカル ストレージ: kafka-reassign-partitions ツールを使用して、パーティション間でトピック データを移行します。

  • クラウド ストレージ: マッピングは変更されますが、トピック データはパーティション間で移行されません。

説明

Professional Edition インスタンスのトピックを作成する場合のみ、ローカル ストレージをストレージ エンジンとして指定できます。

  • ローカル ストレージ: 一時的な内部トラフィックが生成されます。

  • クラウド ストレージ: 一時的な内部トラフィックは生成されません。

クラスターがスケールアウトされるすべてのシナリオ。

  • ローカル ストレージ: 数分または数時間以内。実際の期間は、ローカル ストレージから移行するデータ量によって異なります。データ量が大きい場合、移行には数時間以上かかる場合があります。オフピーク時にデータを移行することをお勧めします。

  • クラウド ストレージ: 数秒以内。トピックの移行には約 30 秒かかります。

リダイレクトしない (非推奨)

操作を実行する必要はありません。元のトピックは、スケールアウト前のクラスターのブローカーに引き続き分散され、新しいトピックはスケールアウト後にすべてのブローカーに均等に分散されます。

  • 元のトピックは、スケールアウト前に購入されたトラフィック仕様の対象となります。

  • 元のトピック トラフィックの量が多い場合、ブローカー間でトラフィックが不均衡になる可能性があります。

  • 元のトピック トラフィックの量が少なく、クラスターのスケールアウト後に大幅に増加しません。

  • トピックは、クラスターのスケールアウト後に作成されます。ほとんどのトラフィックは新しいトピックに送られます。

構成はすぐに有効になります。

手順

説明

サーバーレス ApsaraMQ for Kafka インスタンスでは、トピックのリバランスが自動的にトリガーされます。ApsaraMQ for Kafka コンソールで操作を実行する必要はありません。

  1. ApsaraMQ for Kafka コンソール にログオンします。リソースの分布 セクションの 概要 ページで、管理する ApsaraMQ for Kafka インスタンスが存在するリージョンを選択します。

  2. インスタンスリスト ページで、管理するインスタンスの名前をクリックします。

  3. インスタンスの詳細 ページで、Topic のドレイン概要 セクションの右上隅にある をクリックします。

  4. [インスタンスのトピック トラフィックのリバランス] パネルで、リダイレクト方法 パラメーターを構成します。サポートされているトラフィック リバランス方法については、トラフィック リバランス方法 をご参照ください。

    トラフィック リバランス方法を選択すると、インスタンス上のすべてのトピックが リダイレクト待ち 状態になります。トピック管理 ページの ステータス 列でトピックのステータスを確認できます。

実行結果

トピック トラフィックがリバランスされると、トピックは サービス中 状態になります。トピック管理 ページの ステータス 列でトピックのステータスを確認できます。