4.2. Topic Operator
Topic Operator はカスタムリソースを使用して Kafka トピックをを管理します。
以下のように Topic Operator がデプロイされます。
4.2.1. Topic Operator
Topic Operator は、OpenShift リソースより Kafka クラスターのトピックを管理する方法を提供します。
Topic Operator のアーキテクチャー例
Topic Operator のロールは、対応する Kafka トピックと同期して Kafka トピックを記述する KafkaTopic OpenShift リソースのセットを保持することです。
特に、KafkaTopic が
- 作成されると、Topic Operator によってトピックが作成されます。
- 削除されると、Topic Operator によってトピックが削除されます。
- 変更されると、Topick Operator によってトピックが更新されます。
上記と逆の方向で、トピックが
-
Kafka クラスター内で作成されると、Operator によって
KafkaTopicが作成されます。 -
Kafka クラスターから削除されると、Operator によって
KafkaTopicが削除されます。 -
Kafka クラスターで変更されると、Operator によって
KafkaTopicが更新されます。
このため、KafkaTopic をアプリケーションのデプロイメントの一部として宣言でき、トピックの作成は Topic Operator によって行われます。アプリケーションは、必要なトピックからの作成または消費のみに対処する必要があります。
トピックが再設定された場合や、別の Kafka ノードに再割り当てされた場合、KafkaTopic は常に最新の状態になります。
