5.3. Apache Kafka の Knative ブローカーのインストール

手順

1. Operators Installed Operators に移動します。
2. ページ上部の Project ドロップダウンメニューが Project: knative-eventing に設定されていることを確認します。
3. OpenShift Serverless Operator の Provided APIs のリストで Knative Kafka ボックスを見つけ、Create Instance をクリックします。

4. Create Knative Kafka ページで KnativeKafka オブジェクトを設定します。

   重要

   クラスターで Kafka チャネル、ソース、ブローカー、またはシンクを使用するには、使用するオプションの 有効な スイッチを true に切り替える必要があります。これらのスイッチは、デフォルトで false に設定されます。さらに、Kafka チャネル、ブローカー、またはシンクを使用するには、ブートストラップサーバーを指定する必要があります。

   • KnativeKafka オブジェクトの作成を完全に制御する必要がない、より単純な設定には、このフォームを使用します。

   • KnativeKafka オブジェクトの作成を完全に制御する必要がある、より複雑な設定の場合は YAML を編集します。YAML にアクセスするには、Create Knative Kafka ページの Edit YAML リンクをクリックします。

     KnativeKafka カスタムリソースの例

     apiVersion: operator.serverless.openshift.io/v1alpha1
     kind: KnativeKafka
     metadata:
         name: knative-kafka
         namespace: knative-eventing
     spec:
         channel:
             enabled: true 

     1

     
             bootstrapServers: <bootstrap_servers> 

     2

     
         source:
             enabled: true 

     3

     
         broker:
             enabled: true 

     4

     
             defaultConfig:
                 bootstrapServers: <bootstrap_servers> 

     5

     
                 numPartitions: <num_partitions> 

     6

     
                 replicationFactor: <replication_factor> 

     7

     
         sink:
             enabled: true 

     8

     
         logging:
             level: INFO 

     9

     Copy to Clipboard Toggle word wrap

     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 を使用しないでください。これらのログレベルからの出力は冗長であり、パフォーマンスが低下する可能性があります。

5. Kafka のオプションの設定が完了したら、Create をクリックします。Knative Kafka タブに自動的にダイレクトされます。ここで、knative-kafka はリソースのリストにあります。

検証

1. Knative Kafka タブで knative-kafka リソースをクリックします。Knative Kafka Overview ページに自動的にダイレクトされます。

2. リソースの Conditions (状態) のリストを表示し、それらのステータスが True であることを確認します。

   

   View larger image

   

   状態のステータスが Unknown または False である場合は、ページを更新するためにしばらく待機します。

3. Apache Kafka リソースの Knative ブローカーが作成されたことを確認します。

   $ oc get pods -n knative-eventing

   Copy to Clipboard Toggle word wrap

   出力例

   NAME                                        READY   STATUS    RESTARTS   AGE
   kafka-broker-dispatcher-7769fbbcbb-xgffn    2/2     Running   0          44s
   kafka-broker-receiver-5fb56f7656-fhq8d      2/2     Running   0          44s
   kafka-channel-dispatcher-84fd6cb7f9-k2tjv   2/2     Running   0          44s
   kafka-channel-receiver-9b7f795d5-c76xr      2/2     Running   0          44s
   kafka-controller-6f95659bf6-trd6r           2/2     Running   0          44s
   kafka-source-dispatcher-6bf98bdfff-8bcsn    2/2     Running   0          44s
   kafka-webhook-eventing-68dc95d54b-825xs     2/2     Running   0          44s

   Copy to Clipboard Toggle word wrap