ブローカーサイズの更新

Apache Kafka パーティションを再割り当てせずにブローカーのサイズを変更することで、MSKクラスターをオンデマンドでスケーリングできます。ブローカーのサイズを変更すると、MSKクラスター I/O を中断することなく、ワークロードの変化に基づいてクラスターのコンピューティング容量を柔軟に調整できます。 Amazon MSKは、特定のクラスター内のすべてのブローカーに同じブローカーサイズを使用します。

このセクションでは、MSKクラスターのブローカーサイズを更新する方法について説明します。クラスターブローカーのサイズは、M5 または T3 から M7g に、または M7g から M5 に更新できます。ブローカーサイズを小さくすると、パフォーマンスが低下し、ブローカーごとに達成可能な最大スループットが低下する可能性があることに注意してください。ブローカーサイズを大きくすると、パフォーマンスは向上しますが、コストは高くなります。

ブローカーサイズの更新は、クラスターの起動中および実行中にローリング方式で行われます。つまり、Amazon MSKはブローカーサイズの更新を一度に 1 つのブローカーで実行します。ブローカーサイズの更新中にクラスターを高可用性にする方法については、「」を参照してください高可用性クラスターの構築。生産性への潜在的な影響をさらに軽減するために、トラフィックが少ない期間中にブローカーサイズの更新を実行できます。

ブローカーサイズの更新中も、引き続きデータを生成して使用できます。ただし、ブローカーを再起動したり、Amazon オペレーション にリストされている更新MSKオペレーションを呼び出す前に、更新が完了するまで待つ必要があります。

クラスターをより小さなブローカーサイズに更新する場合は、最初にテストクラスターで更新を試して、シナリオにどのように影響するかを確認することをお勧めします。

重要

ブローカーあたりのパーティション数が で指定された最大数を超えた場合、クラスターをより小さなブローカーサイズに更新することはできません クラスターの適切なサイズ設定: ブローカーあたりのパーティション数。

を使用したブローカーサイズの更新 AWS Management Console

1. で Amazon MSKコンソールを開きますhttps://console.aws.amazon.com/msk/。

2. ブローカーサイズを更新するMSKクラスターを選択します。

3. クラスターの詳細ページで、ブローカーの概要セクションを見つけ、ブローカーサイズの編集を選択します。

4. リストから必要なブローカーサイズを選択します。

5. 変更の保存。

を使用したブローカーサイズの更新 AWS CLI

1. 次のコマンドを実行し、ClusterArn クラスターの作成時に取得した Amazon リソースネーム (ARN) を指定します。クラスターARNに がない場合は、すべてのクラスターを一覧表示することで見つけることができます。詳細については、「Amazon MSKクラスターの一覧表示」を参照してください。

   置換 Current-Cluster-Version クラスターの最新バージョンと TargetType ブローカーにする新しいサイズ。ブローカーサイズの詳細については、「」を参照してくださいブローカーサイズ。

   aws kafka update-broker-type --cluster-arn ClusterArn --current-version Current-Cluster-Version --target-instance-type TargetType

   次に、このコマンドの使用例を示します。

   aws kafka update-broker-type --cluster-arn "arn:aws:kafka:us-east-1:0123456789012:cluster/exampleName/abcd1234-0123-abcd-5678-1234abcd-1" --current-version "K1X5R6FKA87" --target-instance-type kafka.m5.large 

   このコマンドの出力は次のJSON例のようになります。

   {
       "ClusterArn": "arn:aws:kafka:us-east-1:0123456789012:cluster/exampleName/abcd1234-0123-abcd-5678-1234abcd-1",
       "ClusterOperationArn": "arn:aws:kafka:us-east-1:012345678012:cluster-operation/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2/0123abcd-abcd-4f7f-1234-9876543210ef"
   }

2. update-broker-type オペレーションの結果を取得するには、次のコマンドを実行し、ClusterOperationArn update-broker-type コマンドの出力でARN取得した を使用します。

   aws kafka describe-cluster-operation --cluster-operation-arn ClusterOperationArn

   このdescribe-cluster-operationコマンドの出力は次のJSON例のようになります。

   {
     "ClusterOperationInfo": {
       "ClientRequestId": "982168a3-939f-11e9-8a62-538df00285db",
       "ClusterArn": "arn:aws:kafka:us-east-1:0123456789012:cluster/exampleName/abcd1234-0123-abcd-5678-1234abcd-1",
       "CreationTime": "2021-01-09T02:24:22.198000+00:00",
       "OperationArn": "arn:aws:kafka:us-east-1:012345678012:cluster-operation/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2/0123abcd-abcd-4f7f-1234-9876543210ef",
       "OperationState": "UPDATE_COMPLETE",
       "OperationType": "UPDATE_BROKER_TYPE",
       "SourceClusterInfo": {
         "InstanceType": "t3.small"
       },
       "TargetClusterInfo": {
         "InstanceType": "m5.large"
       }
     }
   }

   OperationState の値が UPDATE_IN_PROGRESS の場合は、しばらく待ってから再度 describe-cluster-operation コマンドを実行します。

を使用したブローカーサイズの更新 API

を使用してブローカーサイズを更新するには、API「」を参照してくださいUpdateBrokerType。

を使用してUpdateBrokerType、クラスターブローカーのサイズを M5 または T3 から M7g に、または M7g から M5 に更新できます。