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 代理的默认配置映射。当集群管理员在集群中启用 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 对象位于同一个命名空间中，本例中为 my-namespace。

2. 应用基于 Apache Kafka 的代理 YAML 文件：

   $ oc apply -f <filename>

流程

1. 在 knative-eventing 命名空间中创建证书文件作为 secret：

   $ 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 spec 中添加对 secret 的引用：

   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 命名空间中创建证书文件作为 secret：

   $ 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.不要更改它们。

   • 如果要将 SASL 与公共 CA 证书搭配使用，您必须在创建 secret 时使用 tls.enabled=true 标志，而不是使用 ca.crt 参数。例如：

     $ 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 spec 中添加对 secret 的引用：

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