Aggiorna la versione di Apache Kafka

Apri la console Amazon MSK all'indirizzo https://console.aws.amazon.com/msk/.

Nella barra di navigazione, scegli la regione in cui hai creato il cluster MSK.

Scegli il cluster MSK che desideri aggiornare.

Nella scheda Proprietà, scegli Aggiorna nella sezione della versione di Apache Kafka.

Nella sezione relativa alla versione di Apache Kafka, effettuate le seguenti operazioni:

1. Nell'elenco a discesa Scegli la versione di Apache Kafka, scegli la versione di destinazione a cui desideri eseguire l'aggiornamento. Ad esempio, scegli 3.9.x.

2. (Facoltativo) Scegli Visualizza compatibilità delle versioni per verificare la compatibilità tra la versione corrente del cluster e le versioni di aggiornamento disponibili. Quindi, seleziona Scegli per procedere.

   Nota

   Puoi migrare un ZooKeeper-based cluster alla modalità KRAFT selezionando una versione di KRaft-based destinazione (con un .kraft suffisso). Ciò esegue una migrazione sul posto della gestione dei metadati del cluster da a KRAFT. ZooKeeper Per ulteriori informazioni, consulta Esegui la migrazione dalla modalità ZooKeeper KRAFT.

3. (Facoltativo) Scegli la casella di controllo Aggiorna configurazione del cluster per applicare gli aggiornamenti di configurazione compatibili con la nuova versione. Ciò abilita le funzionalità e i miglioramenti della nuova versione.

   È possibile saltare questo passaggio se è necessario mantenere le configurazioni personalizzate esistenti.

   Nota

   • Server-side gli aggiornamenti non aggiornano automaticamente le applicazioni client.

   • Per mantenere la stabilità del cluster, i downgrade di versione non sono supportati.

4. Scegli Aggiorna per avviare il processo.

Esegui il comando seguente, sostituendolo ClusterArn con l'Amazon Resource Name (ARN) ottenuto durante la creazione del cluster. Se non disponi dell'ARN per il cluster, puoi trovarlo elencando tutti i cluster. Per ulteriori informazioni, consulta Elenca i cluster Amazon MSK.

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

Esegui il comando seguente, sostituendolo ClusterArn con l'Amazon Resource Name (ARN) ottenuto durante la creazione del cluster. Se non disponi dell'ARN per il cluster, puoi trovarlo elencando tutti i cluster. Per ulteriori informazioni, consulta Elenca i cluster Amazon MSK.

Sostituiscilo Current-Cluster-Version con la versione corrente del cluster. Perché TargetVersion è possibile specificare una qualsiasi delle versioni di destinazione dall'output del comando precedente.

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 JSON seguente.

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

Per ottenere il risultato dell'update-cluster-kafka-versionoperazione, esegui il comando seguente, sostituendolo ClusterOperationArn con l'ARN ottenuto nell'output del comando. update-cluster-kafka-version

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

L'output di questo comando describe-cluster-operation è simile all'esempio JSON 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 ad Amazon MSK per completare l'operazione varia, potrebbe essere necessario eseguire ripetutamente il controllo fino al completamento dell'operazione.

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

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