Atualizar a versão do Apache Kafka - Amazon Managed Streaming for Apache Kafka

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Atualizar a versão do Apache Kafka

Você pode atualizar um MSK cluster existente para uma versão mais recente do Apache Kafka. Não é possível atualizá-lo para uma versão mais antiga. Ao atualizar a versão do Apache Kafka de um MSK cluster, verifique também o software do lado do cliente para garantir que sua versão permita que você use os recursos da nova versão do Apache Kafka do cluster. A Amazon atualiza MSK apenas o software do servidor. Ele não atualiza os clientes.

Para obter informações sobre como tornar um cluster altamente disponível durante uma atualização, consulte Criar clusters altamente disponíveis.

Atualize a versão do Apache Kafka usando o AWS Management Console

  1. Abra o MSK console da Amazon emhttps://console.aws.amazon.com/msk/.

  2. Escolha o MSK cluster no qual você deseja atualizar a versão do Apache Kafka.

  3. Na guia Propriedades, escolha Atualizar na seção Versão do Apache Kafka.

Atualize a versão do Apache Kafka usando o AWS CLI

  1. Execute o comando a seguir, ClusterArn substituindo-o pelo Amazon Resource Name (ARN) que você obteve ao criar seu cluster. Se você não tiver o ARN para seu cluster, poderá encontrá-lo listando todos os clusters. Para obter mais informações, consulte Listar MSK clusters da Amazon.

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

    A saída desse comando inclui uma lista das versões do Apache Kafka para as quais você pode atualizar o cluster. Ela se parece com o exemplo a seguir.

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

  2. Execute o comando a seguir, ClusterArn substituindo-o pelo Amazon Resource Name (ARN) que você obteve ao criar seu cluster. Se você não tiver o ARN para seu cluster, poderá encontrá-lo listando todos os clusters. Para obter mais informações, consulte Listar MSK clusters da Amazon.

    Substitua Current-Cluster-Version pela versão atual do cluster. Pois TargetVersion você pode especificar qualquer uma das versões de destino a partir da saída do comando anterior.

    Importante

    As versões de cluster não são inteiros simples. Para encontrar a versão atual do cluster, use a DescribeClusteroperação ou o comando AWS CLI describe-cluster. Uma versão de exemplo é KTVPDKIKX0DER.

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

    A saída do comando anterior se parece com a seguinteJSON.

    {
    
    "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. Para obter o resultado da update-cluster-kafka-version operação, execute o comando a seguir, ClusterOperationArn substituindo-o pelo ARN que você obteve na saída do update-cluster-kafka-version comando.

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

    A saída desse describe-cluster-operation comando se parece com o JSON exemplo a seguir.

    {
    "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 OperationState tiver o valor UPDATE_IN_PROGRESS, aguarde um pouco e execute o comando describe-cluster-operation novamente. Quando a operação for concluída, o valor de OperationState será transformado em UPDATE_COMPLETE. Como o tempo necessário para MSK a Amazon concluir a operação varia, talvez seja necessário verificar repetidamente até que a operação seja concluída.

Atualizar a versão do Apache Kafka usando o API

  1. Invoque a GetCompatibleKafkaVersionsoperação para obter uma lista das versões do Apache Kafka para as quais você pode atualizar o cluster.

  2. Invoque a UpdateClusterKafkaVersionoperação para atualizar o cluster para uma das versões compatíveis do Apache Kafka.