Memperluas MSK cluster Amazon - Amazon Managed Streaming untuk Apache Kafka
Memperluas cluster menggunakan AWS Management ConsoleMemperluas cluster menggunakan AWS CLIMemperluas cluster menggunakan API

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Memperluas MSK cluster Amazon

Gunakan MSK operasi Amazon ini ketika Anda ingin meningkatkan jumlah broker di MSK cluster Anda. Untuk memperluas cluster, pastikan itu dalam ACTIVE keadaan.

penting

Jika Anda ingin memperluas MSK cluster, pastikan untuk menggunakan MSK operasi Amazon ini. Jangan mencoba menambahkan broker ke cluster tanpa menggunakan operasi ini.

Untuk informasi tentang cara menyeimbangkan kembali partisi setelah Anda menambahkan broker ke cluster, lihat. Tetapkan kembali partisi

Memperluas cluster menggunakan AWS Management Console

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

  2. Pilih MSK cluster yang jumlah brokernya ingin Anda tingkatkan.

  3. Pada halaman detail cluster, pilih tombol Edit di sebelah judul Cluster-Level Broker Details.

  4. Masukkan jumlah broker yang Anda inginkan klaster untuk memiliki per Availability Zone dan kemudian pilih Simpan perubahan.

Memperluas cluster 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.

    penting

    Versi cluster bukan bilangan bulat sederhana. Untuk menemukan versi cluster saat ini, gunakan DescribeClusteroperasi atau perintah AWS CLI deskripsi-cluster. Contoh versi adalahKTVPDKIKX0DER.

    Bagian Target-Number-of-Brokers parameter mewakili jumlah total node broker yang Anda ingin cluster untuk memiliki ketika operasi ini selesai dengan sukses. Nilai yang Anda tentukan untuk Target-Number-of-Brokers harus bilangan bulat yang lebih besar dari jumlah broker saat ini di cluster. Itu juga harus kelipatan dari jumlah Availability Zones.

    aws kafka update-broker-count --cluster-arn ClusterArn --current-version Current-Cluster-Version --target-number-of-broker-nodes Target-Number-of-Brokers

    Output dari update-broker-count operasi ini terlihat seperti berikutJSON.

    {
    
    "ClusterArn": "arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2",
    "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-count operasi, jalankan perintah berikut, ganti ClusterOperationArn dengan ARN yang Anda peroleh di output update-broker-count perintah.

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

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

    {
    "ClusterOperationInfo": {
        "ClientRequestId": "c0b7af47-8591-45b5-9c0c-909a1a2c99ea",
        "ClusterArn": "arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2",
        "CreationTime": "2019-09-25T23:48:04.794Z",
        "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": "INCREASE_BROKER_COUNT",
        "SourceClusterInfo": {
            "NumberOfBrokerNodes": 9
        },
        "TargetClusterInfo": {
            "NumberOfBrokerNodes": 12
        }
    }
}

    Dalam output ini, OperationType adalahINCREASE_BROKER_COUNT. Jika OperationState memiliki nilaiUPDATE_IN_PROGRESS, tunggu sebentar, lalu jalankan describe-cluster-operation perintah lagi.

Memperluas cluster menggunakan API

Untuk meningkatkan jumlah broker dalam cluster menggunakanAPI, lihat UpdateBrokerCount.