Mettre à jour la version d'Apache Kafka - Amazon Managed Streaming for Apache Kafka

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Mettre à jour la version d'Apache Kafka

Vous pouvez mettre à jour un MSK cluster existant vers une version plus récente d'Apache Kafka. Vous ne pouvez pas la mettre à jour vers une version plus ancienne. Lorsque vous mettez à jour la version Apache Kafka d'un MSK cluster, vérifiez également votre logiciel côté client pour vous assurer que sa version vous permet d'utiliser les fonctionnalités de la nouvelle version d'Apache Kafka du cluster. Amazon met MSK uniquement à jour le logiciel du serveur. Il ne met pas à jour vos clients.

Pour plus d'informations sur la manière de rendre un cluster hautement disponible lors d'une mise à jour, reportez-vous à la section Créer des clusters hautement disponibles.

Mettez à jour la version d'Apache Kafka à l'aide du AWS Management Console

  1. Ouvrez la MSK console Amazon à l'adressehttps://console.aws.amazon.com/msk/.

  2. Choisissez le MSK cluster sur lequel vous souhaitez mettre à jour la version d'Apache Kafka.

  3. Dans l'onglet Propriétés, choisissez Mettre à niveau dans la section Version Apache Kafka.

Mettez à jour la version d'Apache Kafka à l'aide du AWS CLI

  1. Exécutez la commande suivante, en la ClusterArn remplaçant par le Amazon Resource Name (ARN) que vous avez obtenu lors de la création de votre cluster. Si vous n'en avez pas ARN pour votre cluster, vous pouvez le trouver en listant tous les clusters. Pour de plus amples informations, veuillez consulter Répertorier les MSK clusters Amazon.

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

    La sortie de cette commande inclut une liste des versions d'Apache Kafka vers lesquelles vous pouvez mettre à jour le cluster. Elle ressemble à l'exemple suivant :

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

  2. Exécutez la commande suivante, en la ClusterArn remplaçant par le Amazon Resource Name (ARN) que vous avez obtenu lors de la création de votre cluster. Si vous n'en avez pas ARN pour votre cluster, vous pouvez le trouver en listant tous les clusters. Pour de plus amples informations, veuillez consulter Répertorier les MSK clusters Amazon.

    Remplacez Current-Cluster-Version par la version actuelle du cluster. Car TargetVersion vous pouvez spécifier n'importe quelle version cible à partir de la sortie de la commande précédente.

    Important

    Les versions de cluster ne sont pas des entiers simples. Pour trouver la version actuelle du cluster, utilisez l'DescribeClusteropération ou la commande describe-cluster AWS CLI . Voici un exemple de version : KTVPDKIKX0DER.

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

    Le résultat de la commande précédente ressemble à ce qui suitJSON.

    {
    
    "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. Pour obtenir le résultat de l'update-cluster-kafka-versionopération, exécutez la commande suivante en la ClusterOperationArn remplaçant par ARN celle que vous avez obtenue dans le résultat de la update-cluster-kafka-version commande.

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

    Le résultat de cette describe-cluster-operation commande ressemble à l'JSONexemple suivant.

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

    Si OperationState a la valeur UPDATE_IN_PROGRESS, attendez un moment, puis exécutez à nouveau la commande describe-cluster-operation. Lorsque l'opération est terminée, la valeur de OperationState devient UPDATE_COMPLETE. Étant donné que le temps nécessaire MSK à Amazon pour effectuer l'opération varie, vous devrez peut-être vérifier à plusieurs reprises jusqu'à ce que l'opération soit terminée.

Mettez à jour la version d'Apache Kafka à l'aide du API

  1. Appelez l'GetCompatibleKafkaVersionsopération pour obtenir une liste des versions d'Apache Kafka vers lesquelles vous pouvez mettre à jour le cluster.

  2. Appelez l'UpdateClusterKafkaVersionopération pour mettre à jour le cluster vers l'une des versions compatibles d'Apache Kafka.