5.13.5.2. 创建使用外部管理的 Kafka 主题的 Kafka 代理

如果要在不创建自己的内部主题的情况下使用 Kafka 代理，您可以使用外部管理的 Kafka 主题。要做到这一点，您必须创建一个使用 kafka.eventing.knative.dev/external.topic 注解的 Kafka Broker 对象。

先决条件

  • OpenShift Serverless Operator、Knative Eventing 和 KnativeKafka 自定义资源已安装在 OpenShift Container Platform 集群中。
  • 您可以访问一个 Kafka 实例，如 Red Hat AMQ Streams，并创建了 Kafka 主题。
  • 您已创建了一个项目，或者具有适当的角色和权限访问项目，以便在 OpenShift Container Platform 中创建应用程序和其他工作负载。
  • 已安装 OpenShift CLI(oc)。

流程

  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>