Perbarui versi Apache Kafka - Amazon Managed Streaming untuk Apache Kafka

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

Perbarui versi Apache Kafka

Anda dapat memperbarui MSK cluster yang ada ke versi Apache Kafka yang lebih baru. Anda tidak dapat memperbaruinya ke versi lama. Saat Anda memperbarui versi Apache Kafka dari sebuah MSK cluster, periksa juga perangkat lunak sisi klien Anda untuk memastikan versinya memungkinkan Anda menggunakan fitur versi Apache Kafka baru cluster. Amazon MSK hanya memperbarui perangkat lunak server. Itu tidak memperbarui klien Anda.

Untuk informasi tentang cara membuat klaster sangat tersedia selama pembaruan, lihatBangun cluster yang sangat tersedia.

Perbarui versi Apache Kafka menggunakan AWS Management Console

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

  2. Pilih MSK cluster tempat Anda ingin memperbarui versi Apache Kafka.

  3. Pada tab Properties pilih Upgrade di bagian versi Apache Kafka.

Perbarui versi Apache Kafka 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.

    aws kafka get-compatible-kafka-versions --cluster-arn ClusterArn

    Output dari perintah ini mencakup daftar versi Apache Kafka yang dapat Anda perbarui cluster. Sepertinya contoh berikut.

    {
    "CompatibleKafkaVersions": [
        {
            "SourceVersion": "2.2.1",
            "TargetVersions": [
                "2.3.1",
                "2.4.1",
                "2.4.1.1",
                "2.5.1"
            ]
        }
    ]
}

  2. 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. Untuk TargetVersion Anda dapat menentukan salah satu versi target dari output dari perintah sebelumnya.

    penting

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

    aws kafka update-cluster-kafka-version --cluster-arn ClusterArn --current-version Current-Cluster-Version --target-kafka-version TargetVersion

    Output dari perintah sebelumnya terlihat seperti berikut iniJSON.

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

  3. Untuk mendapatkan hasil update-cluster-kafka-version operasi, jalankan perintah berikut, ganti ClusterOperationArn dengan ARN yang Anda peroleh di output update-cluster-kafka-version perintah.

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

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

    {
    "ClusterOperationInfo": {
        "ClientRequestId": "62cd41d2-1206-4ebf-85a8-dbb2ba0fe259",
        "ClusterArn": "arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2",
        "CreationTime": "2021-03-11T20:34:59.648000+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_IN_PROGRESS",
        "OperationSteps": [
            {
                "StepInfo": {
                    "StepStatus": "IN_PROGRESS"
                },
                "StepName": "INITIALIZE_UPDATE"
            },
            {
                "StepInfo": {
                    "StepStatus": "PENDING"
                },
                "StepName": "UPDATE_APACHE_KAFKA_BINARIES"
            },
            {
                "StepInfo": {
                    "StepStatus": "PENDING"
                },
                "StepName": "FINALIZE_UPDATE"
            }
        ],
        "OperationType": "UPDATE_CLUSTER_KAFKA_VERSION",
        "SourceClusterInfo": {
            "KafkaVersion": "2.4.1"
        },
        "TargetClusterInfo": {
            "KafkaVersion": "2.6.1"
        }
    }
}

    Jika OperationState memiliki nilaiUPDATE_IN_PROGRESS, tunggu sebentar, lalu jalankan describe-cluster-operation perintah lagi. Ketika operasi selesai, nilai OperationState menjadiUPDATE_COMPLETE. Karena waktu yang diperlukan Amazon MSK untuk menyelesaikan operasi bervariasi, Anda mungkin perlu memeriksa berulang kali hingga operasi selesai.

Perbarui versi Apache Kafka menggunakan API

  1. Panggil GetCompatibleKafkaVersionsoperasi untuk mendapatkan daftar versi Apache Kafka yang dapat Anda perbarui cluster.

  2. Panggil UpdateClusterKafkaVersionoperasi untuk memperbarui cluster ke salah satu versi Apache Kafka yang kompatibel.