Amazon MSK クラスターの定常状態の再調整 - Amazon Managed Streaming for Apache Kafka

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Amazon MSK クラスターの定常状態の再調整

定常状態の再調整はインテリジェントな再調整機能の一部であり、Express ブローカーを使用するすべての新しい MSK プロビジョンドクラスターでデフォルトで有効になっています。クラスターをスケールアップまたはスケールダウンすると、Amazon MSK は新しいブローカーにパーティションを配布し、削除のためにブローカーからパーティションを移動することで、パーティション管理を自動的に処理します。ブローカー間でワークロードを最適に分散するために、インテリジェントな再調整では Amazon MSK のベストプラクティスを使用して、ブローカーの再調整を自動的に開始するためのしきい値を決定します。

必要に応じて、定常状態の再調整を一時停止および再開できます。定常状態の再調整は、クラスターを継続的にモニタリングし、以下を実行します。

  • ブローカーリソースの使用状況 (CPU、ネットワーク、ストレージ) を追跡します。

  • データの可用性に影響を与えることなく、パーティションの配置を自動的に調整します。

  • Express ブローカーの再調整オペレーションは、スタンダードブローカーと比較して最大 180 倍速く完了します。

  • クラスターのパフォーマンスを維持します。

トピック
    Pause and resume steady state rebalancing in AWS マネジメントコンソール

    1. https://console.aws.amazon.com/msk/home?region=us-east-1#/home/ で Amazon MSK コンソールを開きます。

    2. クラスターページで、Express ベースのクラスターを選択します。プロビジョニングされた Express ベースのクラスターの作成については、「」を参照してくださいステップ 1: MSK プロビジョニングされたクラスターを作成する。

    3. クラスターの詳細ページで、インテリジェント再調整ステータスがアクティブであることを確認します。インテリジェントリバランシングが利用できない場合、またはステータスが一時停止の場合は、新しい Express ベースのクラスターを作成します。

    4. Actions ドロップダウンリストで、「インテリジェントリバランシングの編集」を選択します。

    5. インテリジェントリバランシングの編集ページで、次の操作を行います。

      1. 一時停止 を選択します。

      2. [Save changes] (変更の保存) をクリックします。

    Pause and resume steady state rebalancing using AWS CLI

    ACTIVE を使用してクラスターの再調整ステータスを に設定するには AWS CLI、次の例に示すように、update-rebalancing コマンドを使用します。このコマンドでは、 rebalancingパラメータを使用してステータスを指定します。

    aws msk update-rebalancing --cluster-arn arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ef-ghij-klmnopqrstuv-1 --current-version ABCDEF1GHIJK0L --rebalancing "{\"Rebalancing\":{\"Status\":\"ACTIVE\"}}"
    Pause and resume steady state rebalancing using AWS SDK

    UpdateRebalancingRequest API を使用してクラスターの再調整ステータスを設定して、ブローカー数をプログラムで変更することもできます。次の例は、再調整ステータスを ACTIVEおよび に設定する方法を示していますPAUSED。

    final UpdateRebalancingRequest updateRebalancingRequest = new UpdateRebalancingRequest()
    .withClusterArn(arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ef-ghij-klmnopqrstuv-1)
    .withCurrentVersion(ABCDEF1GHIJK0L)
    .withRebalancing(new Rebalancing().withStatus("ACTIVE"));
    final UpdateRebalancingRequest updateRebalancingRequest = new UpdateRebalancingRequest()
    .withClusterArn(arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ef-ghij-klmnopqrstuv-1)
    .withCurrentVersion(ABCDEF1GHIJK0L)
    .withRebalancing(new Rebalancing().withStatus("PAUSED"));