5.4. 代理（Broker）

验证

1. 使用 kn 命令列出所有现有代理：

   $ kn broker list

   输出示例

   NAME      URL                                                                     AGE   CONDITIONS   READY   REASON
   default   http://broker-ingress.knative-eventing.svc.cluster.local/test/default   45s   5 OK / 5     True

2. 可选：如果使用 OpenShift Container Platform Web 控制台，在 Developer 视角中进入 Topology 视图来查看存在的代理：

   

流程

1. 创建一个 Trigger 对象作为 YAML 文件，该文件带有 eventing.knative.dev/injection: enabled 注解：

   apiVersion: eventing.knative.dev/v1
   kind: Trigger
   metadata:
     annotations:
       eventing.knative.dev/injection: enabled
     name: <trigger_name>
   spec:
     broker: default
     subscriber: 1
       ref:
         apiVersion: serving.knative.dev/v1
         kind: Service
         name: <service_name>

   1

   指定触发器将事件发送到的事件 sink 或 subscriber。

2. 应用 Trigger YAML 文件：

   $ oc apply -f <filename>

1. 输入以下 oc 命令来获取代理：

   $ oc -n <namespace> get broker default

   输出示例

   NAME      READY     REASON    URL                                                                     AGE
   default   True                http://broker-ingress.knative-eventing.svc.cluster.local/test/default   3m56s

2. 可选：如果使用 OpenShift Container Platform Web 控制台，在 Developer 视角中进入 Topology 视图来查看存在的代理：

   

1. 使用 oc 命令获取代理：

   $ oc -n <namespace> get broker <broker_name>

   示例命令

   $ oc -n default get broker default

   输出示例

   NAME      READY     REASON    URL                                                                     AGE
   default   True                http://broker-ingress.knative-eventing.svc.cluster.local/test/default   3m56s

2. 可选：如果使用 OpenShift Container Platform Web 控制台，在 Developer 视角中进入 Topology 视图来查看存在的代理：

   

流程

1. 从命名空间中删除 eventing.knative.dev/injection=enabled 标识：

   $ oc label namespace <namespace> eventing.knative.dev/injection-

   移除注解可防止 Knative 在删除代理后重新创建代理。

2. 从所选命名空间中删除代理：

   $ oc -n <namespace> delete broker <broker_name>

流程

1. 在 Developer 视角中，进入到 +Add Broker。此时会显示 Broker 页面。
2. 可选。更新代理的名称。如果您没有更新名称，则生成的代理名为 default。
3. 点 Create。

1. 在 Developer 视角中，导航到 Topology。

2. 查看 mt-broker-ingress、mt-broker-filter 和 mt-broker-controller 组件。

   

流程

1. 在 OpenShift Container Platform Web 控制台的 Administrator 视角中，导航到 Serverless Eventing。
2. 在 Create 列表中，选择 Broker。您将进入 Create Broker 页面。
3. 可选：修改代理的 YAML 配置。
4. 点 Create。

流程

1. 修改 kafka-broker-config 配置映射，或创建自己的配置映射来包含以下配置：

   apiVersion: v1
   kind: ConfigMap
   metadata:
     name: <config_map_name> 1
     namespace: <namespace> 2
   data:
     default.topic.partitions: <integer> 3
     default.topic.replication.factor: <integer> 4
     bootstrap.servers: <list_of_servers> 5

   1

   配置映射名称。

   2

   配置映射所在的命名空间。

   3

   Kafka 代理的主题分区数量。这控制如何将事件发送到代理的速度。更多分区需要更多计算资源。

   4

   主题消息的复制因素。这可防止数据丢失。更高的复制因素需要更大的计算资源和更多存储。

   5

   以逗号分隔的 bootstrap 服务器列表。这可以位于 OpenShift Container Platform 集群内部或外部，是代理从发送事件发送到的 Kafka 集群列表。

   重要

   default.topic.replication.factor 值必须小于或等于集群中的 Kafka 代理实例数量。例如，如果您只有一个 Kafka 代理，则 default.topic.replication.factor 值应该不超过 "1"。

   Kafka 代理配置映射示例

   apiVersion: v1
   kind: ConfigMap
   metadata:
     name: kafka-broker-config
     namespace: knative-eventing
   data:
     default.topic.partitions: "10"
     default.topic.replication.factor: "3"
     bootstrap.servers: "my-cluster-kafka-bootstrap.kafka:9092"

2. 应用配置映射：

   $ oc apply -f <config_map_filename>

3. 指定 Kafka Broker 对象的配置映射：

   Broker 对象示例

   apiVersion: eventing.knative.dev/v1
   kind: Broker
   metadata:
     name: <broker_name> 1
     namespace: <namespace> 2
     annotations:
       eventing.knative.dev/broker.class: Kafka 3
   spec:
     config:
       apiVersion: v1
       kind: ConfigMap
       name: <config_map_name> 4
       namespace: <namespace> 5
   ...

   1

   代理名称。

   2

   代理存在的命名空间。

   3

   代理类注解。在本例中，代理是使用类值 Kafka 的 Kafka 代理。

   4

   配置映射名称。

   5

   配置映射所在的命名空间。

4. 应用代理：

   $ oc apply -f <broker_filename>

流程

1. 创建或修改 Trigger 对象并设置 kafka.eventing.knative.dev/delivery.order 注解：

   apiVersion: eventing.knative.dev/v1
   kind: Trigger
   metadata:
     name: <trigger_name>
     annotations:
        kafka.eventing.knative.dev/delivery.order: ordered
   ...

   支持的消费者交付保证有：

   unordered

   未排序的消费者是一种非阻塞消费者，它能以未排序的方式提供消息，同时保持正确的偏移管理。

   排序的

   一个订购的消费者是一个按分区阻止消费者，在提供分区的下一个消息前等待来自 CloudEvent 订阅者成功响应。

   默认排序保证是 unordered。

2. 应用 Trigger 对象：

   $ oc apply -f <filename>