4.6. Apache Kafka の Knative ブローカー実装

手順

1. Kafka ベースのブローカーを YAML ファイルとして作成します。

   apiVersion: eventing.knative.dev/v1
   kind: Broker
   metadata:
     annotations:
       eventing.knative.dev/broker.class: Kafka 

   1

   
     name: example-kafka-broker
   spec:
     config:
       apiVersion: v1
       kind: ConfigMap
       name: kafka-broker-config 

   2

   
       namespace: knative-eventing

   Copy to Clipboard Toggle word wrap

   1

   ブローカークラス。指定されていないと、ブローカーはクラスター管理者の設定に従ってデフォルトクラスを使用します。Kafka ブローカーを使用するには、この値を Kafka にする必要があります。

   2

   Apache Kafka の Knative ブローカーのデフォルトの config map。この config map は、クラスター管理者がクラスター上で Kafka ブローカー機能を有効にした場合に作成されます。

2. Kafka ベースのブローカー YAML ファイルを適用します。

   $ oc apply -f <filename>

   Copy to Clipboard Toggle word wrap

手順

1. Kafka ベースのブローカーを YAML ファイルとして作成します。

   apiVersion: eventing.knative.dev/v1
   kind: Broker
   metadata:
     annotations:
       eventing.knative.dev/broker.class: Kafka 

   1

   
       kafka.eventing.knative.dev/external.topic: <topic_name> 

   2

   
   ...

   Copy to Clipboard Toggle word wrap

   1

   ブローカークラス。指定されていないと、ブローカーはクラスター管理者の設定に従ってデフォルトクラスを使用します。Kafka ブローカーを使用するには、この値を Kafka にする必要があります。

   2

   使用する Kafka トピックの名前。

2. Kafka ベースのブローカー YAML ファイルを適用します。

   $ oc apply -f <filename>

   Copy to Clipboard Toggle word wrap

手順

1. YAML ファイルを使用して Apache Kafka ベースのブローカーを作成します。

   apiVersion: eventing.knative.dev/v1
   kind: Broker
   metadata:
     annotations:
       eventing.knative.dev/broker.class: KafkaNamespaced 

   1

   
     name: default
     namespace: my-namespace 

   2

   
   spec:
     config:
       apiVersion: v1
       kind: ConfigMap
       name: my-config 

   3

   
   ...

   Copy to Clipboard Toggle word wrap

   1

   分離されたデータプレーンで Apache Kafka ブローカーを使用するには、ブローカークラスの値は KafkaNamespaced である必要があります。

   2 3

   参照される ConfigMap オブジェクトの my-config は、Broker オブジェクトと同じ namespace (この場合は my-namespace) に存在する必要があります。

2. Apache Kafka ベースのブローカー YAML ファイルを適用します。

   $ oc apply -f <filename>

   Copy to Clipboard Toggle word wrap

手順

1. 証明書ファイルを knative-eventing namespace にシークレットファイルとして作成します。

   $ oc create secret -n knative-eventing generic <secret_name> \
     --from-literal=protocol=SSL \
     --from-file=ca.crt=caroot.pem \
     --from-file=user.crt=certificate.pem \
     --from-file=user.key=key.pem

   Copy to Clipboard Toggle word wrap
   重要

   キー名に ca.crt、user.crt、および user.key を使用します。これらの値は変更しないでください。

2. KnativeKafka CR を編集し、broker 仕様にシークレットへの参照を追加します。

   apiVersion: operator.serverless.openshift.io/v1alpha1
   kind: KnativeKafka
   metadata:
     namespace: knative-eventing
     name: knative-kafka
   spec:
     broker:
       enabled: true
       defaultConfig:
         authSecretName: <secret_name>
   ...

   Copy to Clipboard Toggle word wrap

手順

1. 証明書ファイルを knative-eventing namespace にシークレットファイルとして作成します。

   $ oc create secret -n knative-eventing generic <secret_name> \
     --from-literal=protocol=SASL_SSL \
     --from-literal=sasl.mechanism=<sasl_mechanism> \
     --from-file=ca.crt=caroot.pem \
     --from-literal=password="SecretPassword" \
     --from-literal=user="my-sasl-user"

   Copy to Clipboard Toggle word wrap

   • キー名 protocol、sasl.mechanism、ca.crt、password、および user を使用します。これらの値は変更しないでください。

     注記

     Kafka クラスターが、システムトラストストアにすでに証明書が存在するパブリック CA によって署名された証明書を使用する場合、ca.crt キーはオプションです。

2. KnativeKafka CR を編集し、broker 仕様にシークレットへの参照を追加します。

   apiVersion: operator.serverless.openshift.io/v1alpha1
   kind: KnativeKafka
   metadata:
     namespace: knative-eventing
     name: knative-kafka
   spec:
     broker:
       enabled: true
       defaultConfig:
         authSecretName: <secret_name>
   ...

   Copy to Clipboard Toggle word wrap