Memperbarui ukuran broker

Anda dapat menskalakan MSK cluster Anda sesuai permintaan dengan mengubah ukuran broker Anda tanpa menetapkan kembali partisi Apache Kafka. Mengubah ukuran broker Anda memberi Anda fleksibilitas untuk menyesuaikan kapasitas komputasi MSK cluster Anda berdasarkan perubahan beban kerja Anda, tanpa mengganggu I/O cluster Anda. Amazon MSK menggunakan ukuran broker yang sama untuk semua broker dalam cluster tertentu.

Bagian ini menjelaskan cara memperbarui ukuran broker untuk MSK cluster Anda. Anda dapat memperbarui ukuran broker cluster Anda dari M5 atau T3 ke m7g, atau dari m7g ke M5. Ketahuilah bahwa bermigrasi ke ukuran broker yang lebih kecil dapat menurunkan kinerja dan mengurangi throughput maksimum yang dapat dicapai per broker. Migrasi ke ukuran broker yang lebih besar dapat meningkatkan kinerja tetapi mungkin lebih mahal.

Pembaruan ukuran broker terjadi secara bergulir saat cluster aktif dan berjalan. Ini berarti bahwa Amazon MSK menurunkan satu broker pada satu waktu untuk melakukan pembaruan ukuran broker. Untuk informasi tentang cara membuat klaster sangat tersedia selama pembaruan ukuran broker, lihat. Membangun cluster yang sangat tersedia Untuk lebih mengurangi dampak potensial pada produktivitas, Anda dapat melakukan pembaruan ukuran broker selama periode lalu lintas rendah.

Selama pembaruan ukuran broker, Anda dapat terus memproduksi dan mengkonsumsi data. Namun, Anda harus menunggu hingga pembaruan selesai sebelum Anda dapat me-reboot broker atau memanggil salah satu operasi pembaruan yang terdaftar di bawah MSKoperasi Amazon.

Jika Anda ingin memperbarui klaster Anda ke ukuran broker yang lebih kecil, kami sarankan Anda mencoba pembaruan pada klaster uji terlebih dahulu untuk melihat bagaimana pengaruhnya terhadap skenario Anda.

penting

Anda tidak dapat memperbarui cluster ke ukuran broker yang lebih kecil jika jumlah partisi per broker melebihi jumlah maksimum yang ditentukan dalam Ukuran kluster Anda dengan benar: Jumlah partisi per broker.

Memperbarui ukuran broker menggunakan AWS Management Console

1. Buka MSK konsol Amazon dihttps://console.aws.amazon.com/msk/.

2. Pilih MSK cluster yang ingin Anda perbarui ukuran broker.

3. Pada halaman detail untuk cluster, temukan bagian ringkasan Broker, dan pilih Edit ukuran broker.

4. Pilih ukuran broker yang Anda inginkan dari daftar.

5. Simpan perubahan.

Memperbarui ukuran broker menggunakan AWS CLI

1. Jalankan perintah berikut, ganti ClusterArn dengan Amazon Resource Name (ARN) yang Anda peroleh saat membuat klaster. Jika Anda tidak memiliki ARN untuk cluster Anda, Anda dapat menemukannya dengan mencantumkan semua cluster. Untuk informasi selengkapnya, lihat Daftar MSK kluster Amazon.

   Ganti Current-Cluster-Version dengan versi cluster saat ini dan TargetType dengan ukuran baru yang Anda inginkan dari broker. Untuk mempelajari lebih lanjut tentang ukuran broker, lihatUkuran broker.

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

   Berikut ini adalah contoh cara menggunakan perintah ini:

   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 

   Output dari perintah ini terlihat seperti JSON contoh berikut.

   {
       "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. Untuk mendapatkan hasil update-broker-type operasi, jalankan perintah berikut, ganti ClusterOperationArn dengan ARN yang Anda peroleh di output update-broker-type perintah.

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

   Output dari describe-cluster-operation perintah ini terlihat seperti JSON contoh berikut.

   {
     "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"
       }
     }
   }

   Jika OperationState memiliki nilaiUPDATE_IN_PROGRESS, tunggu sebentar, lalu jalankan describe-cluster-operation perintah lagi.

Memperbarui ukuran broker menggunakan API

Untuk memperbarui ukuran broker menggunakanAPI, lihat UpdateBrokerType.

Anda dapat menggunakan UpdateBrokerType untuk memperbarui ukuran broker cluster Anda dari M5 atau T3 ke m7G, atau dari m7g ke M5.