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

   1

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

   2

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

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

   $ oc apply -f <filename>

手順

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
   ...

   1

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

   2

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

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

   $ oc apply -f <filename>

手順

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
   ...

   1

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

   2 3

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

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

   $ oc apply -f <filename>

手順

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

   重要

   キー名に 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>
   ...

手順

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"

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

   • パブリック CA 証明書で SASL を使用する場合は、シークレットの作成時に ca.crt 引数ではなく tls.enabled=true フラグを使用する必要があります。以下に例を示します。

     $ oc create secret -n <namespace> generic <kafka_auth_secret> \
       --from-literal=tls.enabled=true \
       --from-literal=password="SecretPassword" \
       --from-literal=saslType="SCRAM-SHA-512" \
       --from-literal=user="my-sasl-user"

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>
   ...