View a markdown version of this page

Tingkatkan 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.

Tingkatkan versi Apache Kafka

Anda dapat memutakhirkan cluster MSK yang ada ke versi Apache Kafka yang lebih baru. Sebelum memutakhirkan versi Kafka cluster Anda, verifikasi bahwa versi perangkat lunak sisi klien Anda mendukung fitur dalam versi Kafka baru.

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

Tingkatkan versi Apache Kafka menggunakan Konsol Manajemen AWS

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

  2. Di bilah navigasi, pilih Wilayah tempat Anda membuat cluster MSK.

  3. Pilih cluster MSK yang ingin Anda upgrade.

  4. Pada tab Properties, pilih Upgrade di bagian versi Apache Kafka.

  5. Di bagian versi Apache Kafka, lakukan hal berikut:

    1. Dalam daftar dropdown Pilih versi Apache Kafka, pilih versi target yang ingin Anda tingkatkan. Misalnya, pilih 3.9.x.

    2. (Opsional) Pilih Lihat kompatibilitas versi untuk memverifikasi kompatibilitas antara versi cluster Anda saat ini dan versi upgrade yang tersedia. Kemudian, pilih Pilih untuk melanjutkan.

      catatan

      Anda dapat memigrasikan ZooKeeper-based cluster ke mode Kraft dengan memilih versi KRaft-based target (dengan akh .kraft iran). Ini melakukan migrasi di tempat dari manajemen metadata cluster Anda dari ZooKeeper ke KraFT. Untuk informasi selengkapnya, lihat Bermigrasi dari ZooKeeper ke mode Kraft.

    3. (Opsional) Pilih kotak centang Perbarui konfigurasi cluster untuk menerapkan pembaruan konfigurasi yang kompatibel dengan versi baru. Ini memungkinkan fitur dan peningkatan versi baru.

      Anda dapat melewati langkah ini jika Anda perlu mempertahankan konfigurasi kustom yang ada.

      catatan

      • Server-side upgrade tidak secara otomatis memperbarui aplikasi klien.

      • Untuk menjaga stabilitas cluster, penurunan versi tidak didukung.

    4. Pilih Upgrade untuk memulai proses.

Tingkatkan versi Apache Kafka menggunakan AWS CLI

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

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

    Output dari perintah ini mencakup daftar versi Apache Kafka yang dapat Anda tingkatkan 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 cluster Anda. Jika Anda tidak memiliki ARN untuk cluster Anda, Anda dapat menemukannya dengan mencantumkan semua cluster. Untuk informasi selengkapnya, lihat Daftar cluster Amazon MSK.

    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 bukanlah bilangan bulat sederhana. Untuk menemukan versi cluster saat ini, gunakan DescribeCluster operasi atau perintah describe-cluster AWS CLI . 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 JSON berikut.

    {
    
    "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 dalam output update-cluster-kafka-version perintah.

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

    Output dari describe-cluster-operation perintah ini terlihat seperti contoh JSON 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 dibutuhkan Amazon MSK untuk menyelesaikan operasi bervariasi, Anda mungkin perlu memeriksa berulang kali hingga operasi selesai.

Tingkatkan versi Apache Kafka menggunakan API

  1. Memanggil GetCompatibleKafkaVersions operasi untuk mendapatkan daftar versi Apache Kafka yang dapat Anda tingkatkan klaster.

  2. Memanggil UpdateClusterKafkaVersion operasi untuk memutakhirkan cluster ke salah satu versi Apache Kafka yang kompatibel.