5.15.2. Kafka 源

您可以创建一个 Kafka 源从 Apache Kafka 集群中读取事件，并将这些事件传递给接收器。您可以使用 OpenShift Container Platform web 控制台、Knative (kn) CLI 或直接创建 KafkaSource 对象并使用 OpenShift CLI (oc) 创建 Kafka 源来应用它。

5.15.2.1. 使用 Web 控制台创建 Kafka 事件源

在集群中安装了 Knative Kafka 后，您可以使用 Web 控制台创建 Kafka 源。使用 OpenShift Container Platform Web 控制台提供了一个简化的用户界面来创建 Kafka 源。

先决条件

  • OpenShift Serverless Operator、Knative Eventing 和 KnativeKafka 自定义资源已安装在集群中。
  • 已登陆到 web 控制台。
  • 您可以访问 Red Hat AMQ Streams（Kafka）集群，该集群会生成您要导入的 Kafka 信息。
  • 您已创建了一个项目，或者具有适当的角色和权限访问项目，以便在 OpenShift Container Platform 中创建应用程序和其他工作负载。

流程

  1. 在 Developer 视角中，导航到 Add 页面并选择 Event Source。
  2. 在 Event Sources 页面中，在 Type 部分选择 Kafka Source。

  3. 配置 Kafka Source 设置：

    1. 添加用逗号分开的 Bootstrap 服务器列表。
    2. 添加以逗号分隔的标题列表。
    3. 添加一个 消费者组。
    4. 为您创建的服务帐户选择 Service Account Name。
    5. 为事件源选择 Sink。Sink 可以是一个 资源，如频道、代理或服务，也可以是一个 URI。
    6. 输入 Kafka 事件源的 名称。
  4. 点 Create。

验证

您可以通过查看 Topology 页面来验证 Kafka 事件源是否已创建并连接到接收器。

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

  2. 查看 Kafka 事件源和接收器。

    在 Topology 视图中查看 Kafka 源和服务