5.3. 事件 sink

流程

1. 创建一个 KafkaSink 对象定义作为一个 YAML 文件：

   Kafka sink YAML

   apiVersion: eventing.knative.dev/v1alpha1
   kind: KafkaSink
   metadata:
     name: <sink-name>
     namespace: <namespace>
   spec:
     topic: <topic-name>
     bootstrapServers:
      - <bootstrap-server>

2. 要创建 Kafka sink，请应用 KafkaSink YAML 文件：

   $ oc apply -f <filename>

3. 配置事件源，以便在其 spec 中指定 sink:

   连接到 API 服务器源的 Kafka sink 示例

   apiVersion: sources.knative.dev/v1alpha2
   kind: ApiServerSource
   metadata:
     name: <source-name> 1
     namespace: <namespace> 2
   spec:
     serviceAccountName: <service-account-name> 3
     mode: Resource
     resources:
     - apiVersion: v1
       kind: Event
     sink:
       ref:
         apiVersion: eventing.knative.dev/v1alpha1
         kind: KafkaSink
         name: <sink-name> 4

   1

   事件源的名称。

   2

   事件源的命名空间。

   3

   事件源的服务帐户。

   4

   Kafka sink 名称。

流程

1. 在 Developer 视角中，进入到 +Add 视图。
2. 点 Eventing 目录中的 Event Sink。
3. 在目录项中搜索 KafkaSink 并点它。
4. 点 Create Event Sink。

5. 在表单视图中，键入 bootstrap 服务器的 URL，这是主机名和端口的组合。

   
6. 键入要发送事件数据的主题名称。
7. 键入事件 sink 的名称。
8. 点 Create。

验证

1. 在 Developer 视角中，进入 Topology 视图。
2. 点创建的事件 sink 在右侧面板中查看其详情。

流程

1. 在与 KafkaSink 对象相同的命名空间中创建一个 secret：

   重要

   证书和密钥必须采用 PEM 格式。

   • 对于使用 SASL 时没有加密的身份验证：

     $ oc create secret -n <namespace> generic <secret_name> \
       --from-literal=protocol=SASL_PLAINTEXT \
       --from-literal=sasl.mechanism=<sasl_mechanism> \
       --from-literal=user=<username> \
       --from-literal=password=<password>

   • 对于使用 TLS 的 SASL 和加密进行身份验证：

     $ oc create secret -n <namespace> generic <secret_name> \
       --from-literal=protocol=SASL_SSL \
       --from-literal=sasl.mechanism=<sasl_mechanism> \
       --from-file=ca.crt=<my_caroot.pem_file_path> \ 1
       --from-literal=user=<username> \
       --from-literal=password=<password>

     1

     如果您使用公共云管理的 Kafka 服务，可以省略 ca.crt 来使用系统的 root CA 设置。

   • 使用 TLS 进行身份验证和加密：

     $ oc create secret -n <namespace> generic <secret_name> \
       --from-literal=protocol=SSL \
       --from-file=ca.crt=<my_caroot.pem_file_path> \ 1
       --from-file=user.crt=<my_cert.pem_file_path> \
       --from-file=user.key=<my_key.pem_file_path>

     1

     如果您使用公共云管理的 Kafka 服务，可以省略 ca.crt 来使用系统的 root CA 设置。

2. 创建或修改 KafkaSink 对象，并在 auth spec 中添加对 secret 的引用：

   apiVersion: eventing.knative.dev/v1alpha1
   kind: KafkaSink
   metadata:
      name: <sink_name>
      namespace: <namespace>
   spec:
   ...
      auth:
        secret:
          ref:
            name: <secret_name>
   ...

3. 应用 KafkaSink 对象：

   $ oc apply -f <filename>