5.3. Apache Kafka の Knative ブローカーのインストール
Apache Kafka の Knative ブローカー実装では、サポートされているバージョンの Apache Kafka メッセージストリーミングプラットフォームを OpenShift Serverless で使用できるように、統合オプションが提供されています。KnativeKafka
カスタムリソースをインストールしている場合、Apache Kafka 機能の Knative ブローカーは OpenShift Serverless インストールで使用できます。
前提条件
- OpenShift Serverless Operator および Knative Eventing がクラスターにインストールされている。
- Red Hat AMQ Streams クラスターにアクセスできる。
-
検証手順を使用する場合は、OpenShift CLI (
oc
) をインストールしている。 - OpenShift Container Platform に対するクラスター管理者権限があるか、Red Hat OpenShift Service on AWS または OpenShift Dedicated に対するクラスターまたは専用管理者権限がある。
- OpenShift Container Platform Web コンソールにログインしている。
手順
-
Administrator パースペクティブで、Operators
Installed Operators に移動します。 - ページ上部の Project ドロップダウンメニューが Project: knative-eventing に設定されていることを確認します。
- OpenShift Serverless Operator の Provided APIs のリストで Knative Kafka ボックスを見つけ、Create Instance をクリックします。
Create Knative Kafka ページで KnativeKafka オブジェクトを設定します。
重要クラスターで Kafka チャネル、ソース、ブローカー、またはシンクを使用するには、使用するオプションの 有効な スイッチを true に切り替える必要があります。これらのスイッチは、デフォルトで false に設定されます。さらに、Kafka チャネル、ブローカー、またはシンクを使用するには、ブートストラップサーバーを指定する必要があります。
- KnativeKafka オブジェクトの作成を完全に制御する必要がない、より単純な設定には、このフォームを使用します。
KnativeKafka オブジェクトの作成を完全に制御する必要がある、より複雑な設定の場合は YAML を編集します。YAML にアクセスするには、Create Knative Kafka ページの Edit YAML リンクをクリックします。
KnativeKafka
カスタムリソースの例Copy to Clipboard Copied! Toggle word wrap Toggle overflow - 1
- 開発者はクラスターで
KafkaChannel
チャネルを使用できます。 - 2
- AMQ Streams クラスターからのブートストラップサーバーのコンマ区切りのリスト。
- 3
- 開発者はクラスターで
KafkaSource
イベントソースタイプを使用できます。 - 4
- 開発者はクラスターで Apache Kafka 用の Knative ブローカー実装を使用できます。
- 5
- Red Hat AMQ Streams クラスターからのブートストラップサーバーのコンマ区切りリスト。
- 6
Broker
オブジェクトでサポートされる Kafka トピックのパーティション数を定義します。デフォルトは10
です。- 7
Broker
オブジェクトでサポートされる Kafka トピックのレプリケーション係数を定義します。デフォルトは3
です。replicationFactor
の値は、Red Hat AMQ Streams クラスターのノード数以下である必要があります。- 8
- 開発者がクラスター内で Kafka シンクを使用できるようにします。
- 9
- Kafka データプレーンのログレベルを定義します。許可される値は、
TRACE
、DEBUG
、INFO
、WARN
、およびERROR
です。デフォルト値はINFO
です。
警告実稼働環境では、ログレベルとして
DEBUG
またはTRACE
を使用しないでください。これらのログレベルからの出力は冗長であり、パフォーマンスが低下する可能性があります。
- Kafka のオプションの設定が完了したら、Create をクリックします。Knative Kafka タブに自動的にダイレクトされます。ここで、knative-kafka はリソースのリストにあります。
検証
- Knative Kafka タブで knative-kafka リソースをクリックします。Knative Kafka Overview ページに自動的にダイレクトされます。
リソースの Conditions (状態) のリストを表示し、それらのステータスが True であることを確認します。
状態のステータスが Unknown または False である場合は、ページを更新するためにしばらく待機します。
Apache Kafka リソースの Knative ブローカーが作成されたことを確認します。
oc get pods -n knative-eventing
$ oc get pods -n knative-eventing
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 出力例
Copy to Clipboard Copied! Toggle word wrap Toggle overflow