3.5. 安装 Knative Eventing

流程

1. 在 OpenShift Container Platform web 控制台的 Administrator 视角中，进入 Operators Installed Operators。
2. 检查页面顶部的 Project 下拉菜单是否已设置为 Project: knative-eventing。
3. 点 OpenShift Serverless Operator 的 Provided APIs 列表中的 Knative Eventing 来进入 Knative Eventing 选项卡。
4. 点 Create Knative Eventing。

5. 在 Create Knative Eventing 页面中，您可以选择使用提供的默认表单或编辑 YAML 来配置 KnativeEventing 对象。

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

     可选。如果您要使用表单配置 KnativeEventing 对象，请为您的 Knative Eventing 部署进行任何要实现的更改。

6. 点 Create。

   • 对于更复杂的配置，建议编辑 YAML，这可以完全控制 KnativeEventing 对象的创建。您可以通过点 Create Knative Eventing 页右上角的 edit YAML 链接来访问 YAML。

     可选。如果您要通过编辑 YAML 配置 KnativeEventing 对象，请对您希望用于 Knative Eventing 部署的 YAML 进行更改。

7. 点 Create。
8. 安装 Knative Eventing 后，会创建 KnativeEventing 对象，并自动定向到 Knative Eventing 选项卡。您可以在资源列表中看到 knative-eventing 自定义资源。

验证

1. 点 Knative Eventing 选项卡中的 knative-eventing 自定义资源。

2. 您会自动定向到 Knative Eventing Overview 页面。

   
3. 向下滚动查看条件列表。

4. 您应该看到一个状况为 True 的条件列表，如示例镜像所示。

   
   注意

   创建 Knative Eventing 资源可能需要几秒钟时间。您可以在 Resources 选项卡中查看其状态。

5. 如果条件状态为 Unknown 或 False，请等待几分钟，然后在确认已创建资源后再重新检查。

流程

1. 创建名为 eventing.yaml 的文件。

2. 将以下示例 YAML 复制到 eventing.yaml中：

   apiVersion: operator.knative.dev/v1beta1
   kind: KnativeEventing
   metadata:
       name: knative-eventing
       namespace: knative-eventing

3. 可选。根据您的 Knative Eventing 部署，对 YAML 进行相应的更改。

4. 输入以下内容来应用 eventing.yaml 文件：

   $ oc apply -f eventing.yaml

验证

1. 输入以下命令验证安装是否完成，并观察输出结果：

   $ oc get knativeeventing.operator.knative.dev/knative-eventing \
     -n knative-eventing \
     --template='{{range .status.conditions}}{{printf "%s=%s\n" .type .status}}{{end}}'

   输出示例

   InstallSucceeded=True
   Ready=True

   注意

   创建 Knative Eventing 资源可能需要几秒钟时间。

2. 如果条件状态为 Unknown 或 False，请等待几分钟，然后在确认已创建资源后再重新检查。

3. 使用以下命令检查是否已创建 Knative Eventing 资源：

   $ oc get pods -n knative-eventing

   输出示例

   NAME                                   READY   STATUS    RESTARTS   AGE
   broker-controller-58765d9d49-g9zp6     1/1     Running   0          7m21s
   eventing-controller-65fdd66b54-jw7bh   1/1     Running   0          7m31s
   eventing-webhook-57fd74b5bd-kvhlz      1/1     Running   0          7m31s
   imc-controller-5b75d458fc-ptvm2        1/1     Running   0          7m19s
   imc-dispatcher-64f6d5fccb-kkc4c        1/1     Running   0          7m18s

流程

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 自定义资源示例

   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

   1

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

   2

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

   3

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

   4

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

   5

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

   6

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

   7

   定义 Kafka 主题的复制因素，由 Broker 对象支持。默认值为 3。

   8

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

   注意

   replicationFactor 值必须小于或等于 Red Hat AMQ Streams 集群的节点数量。

   1. 建议您在不需要完全控制 KnativeKafka 对象创建的简单配置中使用该表单。
   2. 对于更复杂的配置，建议编辑 YAML，这可以完全控制 KnativeKafka 对象的创建。您可以通过点 Create Knative Kafka 页面右上角的 Edit YAML 链接来访问 YAML。
5. 完成 Kafka 的任何可选配置后，点 Create。您会自动定向到 Knative Kafka 标签页，其中 knative-kafka 在资源列表中。

验证

1. 点 Knative Kafka 选项卡中的 knative-kafka 资源。您会自动定向到 Knative Kafka Overview 页面。

2. 查看资源的 Conditions 列表，并确认其状态为 True。

   

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

3. 检查是否已创建 Knative Kafka 资源：

   $ 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