View a markdown version of this page

액티브-액티브 복제 - Amazon Managed Streaming for Apache Kafka

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

액티브-액티브 복제

액티브-액티브 설정에서는 두 MSK 클러스터가 모두 읽기 및 쓰기를 적극적으로 제공합니다. 액티브-액티브 클러스터 토폴로지는 복구 시간이 거의 없으며 스트리밍 애플리케이션이 여러 AWS 리전에서 동시에 작동할 수 있는 기능을 제공합니다.

접두사 주제 이름 복제 사용(권장)

액티브-액티브 설정에 접두사 주제 이름 복제(콘솔의 주제 이름에 접두사 추가)를 사용하는 것이 좋습니다. 이렇게 하려면 복제된 주제를 읽도록 소비자를 재구성해야 하지만 추가 데이터 처리 요금이 부과되지 않습니다.

  1. MSK 클러스터 A를 소스로, MSK 클러스터 B를 대상으로 하는 MSK Replicator를 생성합니다.

  2. 위의 MSK Replicator가 성공적으로 생성되면 클러스터 B를 소스로, 클러스터 A를 대상으로 복제기를 생성합니다.

  3. 생산자와 동일한 리전에 있는 클러스터의 로컬 주제(예: "주제")에 각각 동시에 데이터를 쓰는 두 개의 생산자 세트를 생성합니다.

  4. 소비자와 동일한 AWS 리전에 있는 MSK 클러스터에서 와일드카드 구독(예: .*topic)을 사용하여 각각 데이터를 읽는 두 개의 소비자 세트를 생성합니다. 이렇게 하면 소비자가 로컬 주제(예: topic)에서 로컬로 생성된 데이터와 접두사가 인 주제의 다른 리전에서 복제된 데이터를 자동으로 읽습니다<sourceKafkaClusterAlias>.topic. 이 두 소비자 세트는 서로 다른 소비자 그룹 ID를 가져야 MSK Replicator가 다른 클러스터로 복사할 때 소비자 그룹 오프셋이 덮어쓰지 않습니다.

동일한 주제 이름 복제 사용

클라이언트 재구성을 피하려면 동일한 주제 이름 복제를 사용하여 MSK 복제기를 생성할 수 있습니다(콘솔에서 동일한 주제 이름 유지). 하지만 각 Replicator에 대해 추가 데이터 처리 및 데이터 전송 요금을 지불하게 됩니다. 이는 각 Replicator가 일반적인 데이터 양을 두 번(복제를 위해 한 번, 무한 루프를 방지하기 위해 다시 한 번) 처리해야 하기 때문입니다. ReplicatorBytesInPerSec 지표를 사용하여 각 Replicator가 처리하는 총 데이터 양을 추적할 수 있습니다.

참고

액티브-액티브 토폴로지에 동일한 주제 이름 복제를 사용하는 경우 주제를 삭제한 후 30초 이상 기다린 후 동일한 이름으로 주제를 다시 생성합니다. 이 대기 기간은 중복된 메시지가 소스 클러스터로 다시 복제되는 것을 방지하는 데 도움이 됩니다. 소비자는 다운스트림에 영향을 주지 않으면서 중복된 메시지를 재처리할 수 있어야 합니다.