View a markdown version of this page

Amazon MSK 클러스터의 정상 상태 재분배 - Amazon Managed Streaming for Apache Kafka

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Amazon MSK 클러스터의 정상 상태 재분배

정상 상태 리밸런싱은 Express 브로커가 있는 모든 새 MSK 프로비저닝 클러스터에 대해 기본적으로 활성화되는 지능형 리밸런싱 기능의 일부입니다. 클러스터를 확장하거나 축소하면 Amazon MSK는 파티션을 새 브로커에 배포하고 제거 예정인 브로커에서 파티션을 이동하여 파티션 관리를 자동으로 처리합니다. 브로커 간에 워크로드를 최적으로 분산하기 위해 지능형 리밸런싱은 Amazon MSK 모범 사례를 사용하여 브로커에 대한 리밸런싱을 자동으로 시작하기 위한 임계값을 결정합니다.

필요한 경우 안정 상태 재분배를 일시 중지했다가 재개할 수 있습니다. 정상 상태 리밸런싱은 클러스터를 지속적으로 모니터링하고 다음을 수행합니다.

  • 브로커 리소스 사용량(CPU, 네트워크, 스토리지)을 추적합니다.

  • 데이터 가용성에 영향을 주지 않고 파티션 배치를 자동으로 조정합니다.

  • 표준 브로커에 비해 Express 브로커에서 최대 180배 빠른 리밸런싱 작업을 완료합니다.

  • 클러스터 성능을 유지합니다.

주제
    Pause and resume steady state rebalancing in AWS Management Console

    1. https://console.aws.amazon.com/msk/home?region=us-east-1#/home/에서 Amazon MSK 콘솔을 엽니다.

    2. 클러스터 페이지에서 Express 기반 클러스터를 선택합니다. 프로비저닝된 Express 기반 클러스터 생성에 대한 자세한 내용은 섹션을 참조하세요1단계: MSK Provisioned 클러스터 생성.

    3. 클러스터 세부 정보 페이지에서 지능형 리밸런싱 상태가 활성인지 확인합니다. 지능형 리밸런싱을 사용할 수 없거나 상태가 일시 중지됨인 경우 새 Express 기반 클러스터를 생성합니다.

    4. 작업 드롭다운 목록에서 지능형 재분배 편집을 선택합니다.

    5. 지능형 리밸런싱 편집 페이지에서 다음을 수행합니다.

      1. 일시 중지됨을 선택합니다.

      2. 변경 사항 저장을 선택합니다.

    Pause and resume steady state rebalancing using AWS CLI

    를 ACTIVE 사용하여 클러스터의 리밸런싱 상태를 로 설정하려면 다음 예제와 같이 update-rebalancing 명령을 AWS CLI사용합니다. 이 명령에서 rebalancing 파라미터를 사용하여 상태를 지정합니다.

    aws msk update-rebalancing --cluster-arn arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ef-ghij-klmnopqrstuv-1 --current-version ABCDEF1GHIJK0L --rebalancing "{\"Rebalancing\":{\"Status\":\"ACTIVE\"}}"
    Pause and resume steady state rebalancing using AWS SDK

    UpdateRebalancingRequest API를 사용하여 클러스터의 리밸런싱 상태를 설정하여 브로커 수를 프로그래밍 방식으로 수정할 수도 있습니다. 다음 예제에서는 리밸런싱 상태를 ACTIVE 및 로 설정하는 방법을 보여줍니다PAUSED.

    final UpdateRebalancingRequest updateRebalancingRequest = new UpdateRebalancingRequest()
    .withClusterArn(arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ef-ghij-klmnopqrstuv-1)
    .withCurrentVersion(ABCDEF1GHIJK0L)
    .withRebalancing(new Rebalancing().withStatus("ACTIVE"));
    final UpdateRebalancingRequest updateRebalancingRequest = new UpdateRebalancingRequest()
    .withClusterArn(arn:aws:kafka:us-east-1:123456789012:cluster/myCluster/abcd1234-5678-90ef-ghij-klmnopqrstuv-1)
    .withCurrentVersion(ABCDEF1GHIJK0L)
    .withRebalancing(new Rebalancing().withStatus("PAUSED"));