Apache Kafka 버전 업그레이드

https://console.aws.amazon.com/msk/에서 Amazon MSK 콘솔을 엽니다.

탐색 모음에서 MSK 클러스터를 생성한 리전을 선택합니다.

업그레이드할 MSK 클러스터를 선택합니다.

속성 탭의 Apache Kafka 버전 섹션에서 업그레이드를 선택합니다.

Apache Kafka 버전 섹션에서 다음을 수행합니다.

1. Apache Kafka 버전 선택 드롭다운 목록에서 업그레이드할 버전을 선택합니다. 예를 들어 3.9.x를 선택합니다.

2. (선택 사항) 클러스터의 현재 버전과 업그레이드하려는 버전 간의 호환성을 보려면 버전 호환성을 선택합니다. 그런 다음 선택을 선택하여 진행하거나 취소를 선택합니다.

3. 클러스터 구성 업데이트 확인란을 선택하여 업그레이드된 버전과 호환되는 새 Kafka 구성 개정을 자동으로 적용합니다. 이렇게 하면 호환성이 보장되고 업그레이드된 버전의 새로운 기능 또는 개선 사항이 활성화됩니다. 그러나 기존 사용자 지정 구성을 유지하려면 건너뜁니다.

4. Upgrade(업그레이드)를 선택합니다.

다음 명령을 실행하여 ClusterArn을 클러스터 생성 후 받은 Amazon 리소스 이름(ARN)으로 바꿉니다. 클러스터에 대한 ARN이 없는 경우, 모든 클러스터를 나열하여 찾을 수 있습니다. 자세한 내용은 Amazon MSK 클러스터 나열 단원을 참조하십시오.

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

이 명령의 출력에는 클러스터를 업그레이드할 수 있는 Apache Kafka 버전 목록이 포함됩니다. 다음 예제와 같습니다.

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

다음 명령을 실행하여 ClusterArn을 클러스터 생성 후 받은 Amazon 리소스 이름(ARN)으로 바꿉니다. 클러스터에 대한 ARN이 없는 경우, 모든 클러스터를 나열하여 찾을 수 있습니다. 자세한 내용은 Amazon MSK 클러스터 나열 단원을 참조하십시오.

Current-Cluster-Version을 클러스터의 현재 버전으로 바꿉니다. TargetVersion의 경우 이전 명령의 출력에서 대상 버전을 지정할 수 있습니다.

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

이전 명령의 출력은 다음 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"
}

update-cluster-kafka-version 작업 결과를 가져오려면 다음 명령을 실행하여 ClusterOperationArn을 update-cluster-kafka-version 명령 출력에서 가져온 ARN으로 바꿉니다.

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

이 describe-cluster-operation 명령의 출력은 다음 JSON 예제와 같습니다.

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

OperationState 값이 UPDATE_IN_PROGRESS인 경우, 잠시 기다린 다음 describe-cluster-operation 명령을 다시 실행합니다. 작업이 완료되면 OperationState의 값이 UPDATE_COMPLETE가 됩니다. Amazon MSK가 작업을 완료하는 데 걸리는 시간은 다양하므로 작업이 완료될 때까지 반복해서 확인해야 할 수 있습니다.

GetCompatibleKafkaVersions 작업을 호출하여 클러스터를 업그레이드할 수 있는 Apache Kafka 버전 목록을 가져옵니다.

UpdateClusterKafkaVersion 작업을 호출하여 클러스터를 호환되는 Apache Kafka 버전 중 하나로 업그레이드합니다.