6.2. Topic Operator
Topic Operator は、KafkaTopic
リソースを通じて Kafka クラスター内のトピックを管理する方法を提供します。
Topic Operator のアーキテクチャー例
Topic Operator は、Kafka を記述する KafkaTopic
リソースを監視し、それらが Kafka クラスター内で適切に設定されていることを確認することによって、Kafka トピックを管理します。
KafkaTopic
が作成、削除、または変更されると、Topic Operator は Kafka トピックに対して対応するアクションを実行します。
アプリケーションのデプロイメントの一部として KafkaTopic
を宣言すると、Topic Operator が Kafka トピックを管理します。
Topic Operator は次のモードで動作します。
- 双方向モード
双方向モードは、Topic Operator が
KafkaTopic
リソースに対する変更を Kafka クラスターとの間で調整できることを意味します。これは、KafkaTopic
リソースを介して、または Kafka で直接トピックを更新でき、トピックオペレーターは両方のソースが更新されて変更が反映されることを保証することを意味します。このモードでは、クラスター管理に ZooKeeper が必要です。Topic Operator は、各トピックに関する情報を topic store に保持し、OpenShift
KafkaTopic
カスタムリソースまたは Kafka トピックからの更新と継続的に同期します。ローカルのインメモリートピックストアに適用される操作からの更新は、ディスク上のバックアップトピックストアに永続化されます。- 一方向モード (プレビュー)
-
一方向モードは、Topic Operator が
KafkaTopic
リソースを通じてトピックをのみ管理することを意味します。このモードは ZooKeeper を必要とせず、KRaft モードでの AMQ Streams の使用と互換性があります。