6.2. 주제 Operator
Topic Operator는 OpenShift 리소스를 통해 Kafka 클러스터에서 주제를 관리하는 방법을 제공합니다.
Topic Operator의 아키텍처 예
Topic Operator의 역할은 해당 Kafka 주제와의 동기화에서 Kafka 주제를 설명하는 KafkaTopic OpenShift 리소스 세트를 유지하는 것입니다.
특히 KafkaTopic 이 있는 경우:
- 생성된 주제 Operator에서 주제를 생성합니다.
- 삭제된 주제를 삭제합니다.
- 변경되어 Topic Operator에서 주제를 업데이트합니다.
주제가 있는 경우 다른 방향으로 작업합니다.
-
Kafka 클러스터 내에서 생성된 Operator는
KafkaTopic을 생성합니다. -
Kafka 클러스터에서 삭제된 Operator는
KafkaTopic을 삭제합니다. -
Kafka 클러스터에서 변경되어 Operator는
KafkaTopic을 업데이트합니다.
이를 통해 KafkaTopic 을 애플리케이션 배포의 일부로 선언할 수 있으며 Topic Operator는 해당 주제를 생성합니다. 애플리케이션은 필요한 주제를 생성하거나 소비하기만 하면 됩니다.
Topic Operator는 Kafka 주제 또는 OpenShift KafkaTopic 사용자 정의 리소스의 업데이트와 지속적으로 동기화되는 주제 저장소 의 각 항목에 대한 정보를 유지 관리합니다. 로컬 메모리 내 주제 저장소에 적용되는 작업에서의 업데이트는 디스크의 백업 주제 저장소에 유지됩니다. 주제를 재구성하거나 다른 브로커에 다시 할당하면 KafkaTopic 이 항상 최신 상태가 됩니다.