5.3. 为 Apache Kafka 安装 Knative 代理

流程

1. 在 Administrator 视角中，进入 Operators Installed Operators。
2. 检查页面顶部的 Project 下拉菜单是否已设置为 Project: knative-eventing。
3. 在 OpenShift Serverless Operator 的 Provided APIs 列表中，找到 Knative Kafka 复选框并点 Create Instance。

4. 在 Create Knative Kafka 页面中配置 KnativeKafka 对象。

   重要

   要在集群中使用 Kafka 频道、源、代理或 sink，您需要将要使用的属性的 enabled 选项设置为 true。这些交换机默认设置为 false。另外，要使用 Kafka 频道、代理或接收器，您必须指定 bootstrap 服务器。

   • 在不需要完全控制 KnativeKafka 对象创建的简单配置中使用表单。

   • 编辑 YAML 以获取更复杂的配置，这些配置需要完全控制 KnativeKafka 对象创建。您可以通过点 Create Knative Kafka 页面中的 Edit YAML 链接来访问 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

     1

     让开发人员在集群中使用 KafkaChannel 频道类型。

     2

     以逗号分隔的 AMQ Streams 集群中的 bootstrap 服务器列表。

     3

     让开发人员在集群中使用 KafkaSource 事件源类型。

     4

     让开发人员在集群中使用 Apache Kafka 的 Knative 代理实现。

     5

     来自 Red Hat AMQ Streams 集群的 bootstrap 服务器的逗号分隔列表。

     6

     定义 Kafka 主题分区的数量，由 Broker 对象支持。默认值为 10。

     7

     定义 Kafka 主题的复制因素，由 Broker 对象支持。默认值为 3。replicationFactor 值必须小于或等于 Red Hat AMQ Streams 集群的节点数量。

     8

     让开发人员在集群中使用 Kafka sink。

     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。

   

   如果条件的状态为 Unknown 或 False，请等待几分钟刷新页面。

3. 检查是否已创建 Apache Kafka 资源的 Knative 代理：

   $ oc get pods -n knative-eventing

   输出示例

   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