Atualize 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á.

Atualize a versão do Apache Kafka

Você pode atualizar um cluster MSK existente para uma versão mais recente do Apache Kafka.

nota

  • Você não pode atualizar um cluster MSK existente de uma versão ZooKeeper baseada no Apache Kafka para uma versão mais recente que use ou exija o modo. KRaft Em vez disso, para atualizar seu cluster, crie um novo cluster MSK com uma versão KRaft compatível com o Kafka e migre seus dados e cargas de trabalho do cluster antigo.

  • O Amazon MSK atualiza somente o software do servidor. Isso não atualiza seus clientes.

  • Você não pode fazer o downgrade de um cluster MSK existente para uma versão mais antiga do Apache Kafka.

Ao atualizar a versão Apache Kafka de um cluster MSK, 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.

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

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

  1. Abra o console do Amazon MSK em https://console.aws.amazon.com/msk/.

  2. Na barra de navegação, escolha a região em que você criou o cluster MSK.

  3. Escolha o cluster MSK que você deseja atualizar.

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

  5. Na seção de versão do Apache Kafka, faça o seguinte:

    1. Na lista suspensa Escolha a versão do Apache Kafka, escolha a versão para a qual você deseja atualizar. Para este exemplo, selecione 3.9.x.

    2. (Opcional) Escolha Compatibilidade de versão para ver a compatibilidade entre a versão atual do cluster e a versão para a qual você deseja fazer o upgrade. Em seguida, escolha Escolher para continuar ou escolha Cancelar.

    3. Escolha a caixa de seleção Atualizar configuração do cluster para aplicar automaticamente uma nova revisão de configuração do Kafka que seja compatível com a versão atualizada. Isso garante a compatibilidade e permite novos recursos ou melhorias na versão atualizada. No entanto, ignore-a se quiser manter suas configurações personalizadas existentes.

    4. Escolha Atualizar.

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

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

    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, substituindo ClusterArn pelo nome do recurso da Amazon (ARN) que você obteve quando criou o cluster. Se você não tiver o ARN do cluster, poderá encontrá-lo listando todos os clusters. Para obter mais informações, consulte Listar clusters do Amazon MSK.

    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 é semelhante ao JSON a seguir.

    {
    
    "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 obtido na saída do update-cluster-kafka-version comando.

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

    A saída desse comando describe-cluster-operation é semelhante ao seguinte JSON de exemplo.

    {
    "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 que o Amazon MSK conclua a operação varia, talvez seja necessário verificar repetidamente até que a operação seja concluída.

Atualize a versão do Apache Kafka usando a 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.