9장. Topic Operator를 사용하여 Kafka 주제 관리
KafkaTopic 리소스는 파티션 및 복제 요소 설정을 포함하여 주제를 구성합니다. KafkaTopic 을 사용하여 주제를 생성, 수정 또는 삭제할 때 Topic Operator는 이러한 변경 사항이 Kafka 클러스터에 반영되도록 합니다.
KafkaTopic 리소스에 대한 자세한 내용은 KafkaTopic 스키마 참조를 참조하십시오.
9.1. 주제 관리 모드 링크 복사링크가 클립보드에 복사되었습니다!
KafkaTopic 리소스는 Kafka 클러스터 내에서 단일 주제를 관리합니다. Topic Operator는 KafkaTopic 리소스 및 Kafka 주제를 관리하기 위한 두 가지 모드를 제공합니다.
- 양방향 모드
- 양방향 모드를 사용하려면 클러스터 관리를 위해 Zoo Cryostat가 필요합니다. KRaft 모드에서 AMQ Streams 사용과 호환되지 않습니다.
- (Preview) Unidirectional 모드
- Unidirectional 모드에서는 클러스터 관리를 위해 Zoo Cryostat가 필요하지 않습니다. KRaft 모드에서 AMQ Streams를 사용하는 것과 호환됩니다.
Unidirectional 주제 관리는 프리뷰로 사용할 수 있습니다. Unidirectional 주제 관리는 기본적으로 활성화되어 있지 않으므로 UnidirectionalTopicOperator 기능 게이트를 활성화해야 합니다.
9.1.1. 양방향 주제 관리 링크 복사링크가 클립보드에 복사되었습니다!
양방향 모드에서 Topic Operator는 다음과 같이 작동합니다.
-
KafkaTopic이 생성, 삭제 또는 변경되면 Topic Operator가 Kafka 주제에서 해당 작업을 수행합니다. -
마찬가지로 Kafka 클러스터 내에서 주제를 생성, 삭제 또는 변경할 때 Topic Operator는
KafkaTopic리소스에서 해당 작업을 수행합니다.
KafkaTopic 리소스를 통해 또는 Kafka에서 직접 주제 관리 방법을 유지합니다. 지정된 항목에 대한 두 방법 모두 정기적으로 전환하지 않도록 합니다.
9.1.2. (Preview) Unidirectional 주제 관리 링크 복사링크가 클립보드에 복사되었습니다!
unidirectional 모드에서 Topic Operator는 다음과 같이 작동합니다.
-
KafkaTopic이 생성, 삭제 또는 변경되면 Topic Operator가 Kafka 주제에서 해당 작업을 수행합니다.
해당 KafkaTopic 리소스가 없으면 Kafka 클러스터 내에서 직접 생성, 삭제 또는 수정된 주제가 있는 경우 Topic Operator는 해당 주제를 관리하지 않습니다. Topic Operator는 KafkaTopic 리소스와 관련된 Kafka 주제만 관리하고 Kafka 클러스터 내에서 독립적으로 관리되는 주제를 방해하지 않습니다. Kafka 항목에 대한 KafkaTopic 이 있는 경우 리소스 외부에서 수행된 구성 변경 사항이 되돌아갑니다.
Topic Operator는 동일한 .spec.topicName 을 사용하여 여러 KafkaTopic 리소스가 Kafka 주제를 관리하려고 하는 경우를 감지할 수 있습니다. 가장 오래된 리소스만 조정되지만 다른 리소스는 리소스 충돌 오류와 함께 실패합니다.