계획된 장애 조치

계획된 장애 조치를 수행하여 기본 AWS 리전에서 예상치 못한 이벤트에 대한 애플리케이션의 복원력을 테스트할 수 있습니다. 계획된 장애 조치로 인해 데이터가 손실되어서는 안 됩니다.

Identical topic name replication

1. 소스 클러스터에 연결하는 모든 생산자 및 소비자를 종료합니다.

2. 새 MSK Replicator를 생성하여 보조 리전의 MSK 클러스터에서 기본 리전의 MSK 클러스터로 동일한 주제 이름 복제를 통해 데이터를 복제합니다(콘솔에서 동일한 주제 이름 유지). 이는 장애 복구를 위해 보조 리전에 기록된 데이터를 기본 리전에 다시 복사하는 데 필요합니다.

3. 보조 AWS 리전의 대상 클러스터에 연결된 생산자 및 소비자를 시작합니다.

Prefixed topic name replication

1. 소스 클러스터에 연결하는 모든 생산자 및 소비자를 종료합니다.

2. 새 MSK Replicator를 생성하여 보조 리전의 MSK 클러스터에서 기본 리전의 MSK 클러스터로 데이터를 복제합니다. 이는 장애 복구에 필요합니다.

3. 보조 AWS 리전의 대상 클러스터에서 생산자를 시작합니다.

4. 애플리케이션에 메시지 순서 지정이 필요하지 않은 경우 와일드카드 연산자(예: topic)를 사용하여 로컬(예: ) 및 복제된 주제(예: <sourceKafkaClusterAlias>.topic) 모두에서 읽는 보조 AWS 리전에서 소비자를 시작합니다.*topic.

   애플리케이션에 메시지 순서 지정이 필요한 경우 대상 클러스터의 복제된 주제(예: <sourceKafkaClusterAlias>.topic)에 대해서만 소비자를 시작하고 로컬 주제에 대해서는 시작하지 않습니다.

5. 대상 MSK 클러스터에 복제된 주제의 모든 소비자가 모든 데이터 처리를 완료할 때까지 기다렸다가 소비자 지연이 0이 되도록 합니다. 그런 다음 복제된 주제에 대한 소비자를 중지합니다.

6. 대상 MSK 클러스터에서 로컬 주제(예: topic)에 대한 소비자를 시작합니다.