Aggiorna la versione di Apache Kafka - Amazon Managed Streaming per Apache Kafka

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Aggiorna la versione di Apache Kafka

È possibile aggiornare un MSK cluster esistente a una versione più recente di Apache Kafka. Non puoi aggiornarlo a una versione precedente. Quando aggiorni la versione di Apache Kafka di un MSK cluster, controlla anche il software sul lato client per assicurarti che la versione consenta di utilizzare le funzionalità della nuova versione di Apache Kafka del cluster. Amazon aggiorna MSK solo il software del server. Non aggiorna i clienti.

Per informazioni su come rendere un cluster altamente disponibile durante un aggiornamento, consulta Creazione di cluster a disponibilità elevata.

Aggiorna la versione di Apache Kafka utilizzando il AWS Management Console

  1. Apri la MSK console Amazon all'indirizzohttps://console.aws.amazon.com/msk/.

  2. Scegli il MSK cluster su cui desideri aggiornare la versione di Apache Kafka.

  3. Nella scheda Proprietà, scegli Aggiorna nella sezione relativa alla versione di Apache Kafka.

Aggiorna la versione di Apache Kafka usando il AWS CLI

  1. Eseguite il seguente comando, sostituendo ClusterArn con l'Amazon Resource Name (ARN) che hai ottenuto quando hai creato il cluster. Se non disponi del codice ARN per il tuo cluster, puoi trovarlo elencando tutti i cluster. Per ulteriori informazioni, consulta Elenca i MSK cluster Amazon.

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

    L'output di questo comando include un elenco delle versioni di Apache Kafka a cui è possibile aggiornare il cluster. Il risultato sembra l'esempio seguente.

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

  2. Esegui il comando seguente, sostituendo ClusterArn con l'Amazon Resource Name (ARN) che hai ottenuto quando hai creato il cluster. Se non disponi del codice ARN per il tuo cluster, puoi trovarlo elencando tutti i cluster. Per ulteriori informazioni, consulta Elenca i MSK cluster Amazon.

    Replace (Sostituisci) Current-Cluster-Version con la versione corrente del cluster. In TargetVersion è possibile specificare una qualsiasi delle versioni di destinazione dall'output del comando precedente.

    Importante

    Le versioni del cluster non sono interi semplici. Per trovare la versione corrente del cluster, utilizzate l'DescribeClusteroperazione o il comando AWS CLI describe-cluster. Una versione di esempio è KTVPDKIKX0DER.

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

    L'output del comando precedente è simile al seguente. JSON

    {
    
    "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. Per ottenere il risultato dell'update-cluster-kafka-versionoperazione, esegui il comando seguente, sostituendo ClusterOperationArn con ARN quello ottenuto nell'output del update-cluster-kafka-version comando.

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

    L'output di questo describe-cluster-operation comando è simile all'JSONesempio seguente.

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

    Se il valore di OperationState è UPDATE_IN_PROGRESS, attendi qualche minuto, quindi esegui nuovamente il comando describe-cluster-operation. Al termine dell'operazione, il valore di OperationState diventa UPDATE_COMPLETE. Poiché il tempo necessario MSK ad Amazon per completare l'operazione varia, potrebbe essere necessario controllare ripetutamente fino al completamento dell'operazione.

Aggiorna la versione di Apache Kafka usando il API

  1. Richiama l'GetCompatibleKafkaVersionsoperazione per ottenere un elenco delle versioni di Apache Kafka a cui è possibile aggiornare il cluster.

  2. Richiama l'UpdateClusterKafkaVersionoperazione per aggiornare il cluster a una delle versioni compatibili di Apache Kafka.