15.2. 创建到 Kafka 代理的连接

在集成中,若要从 Kafka 主题订阅数据或将数据发布到 Kafka 主题,请创建一个到 Kafka 的连接,然后将该连接添加到集成。

先决条件

  • 您可以在集群中启用了 Kafka 代理的自动发现,如 启用 Kafka 代理/AMQ Streams 的自动发现 中所述。或者,您知道您要连接的 Kafka 代理的 URI。
  • 如果要使用传输层安全(TLS)加密数据,则具有 Kafka 代理的 PEM 证书文本。通常,您可以从 Kafka 服务器管理员获取代理证书文本。

流程

  1. 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示任何可用连接。
  2. Create Connection 以显示连接器。
  3. Kafka Message Broker 连接器。
  4. Kafka broker URIs 字段中,选择您希望此连接访问的代理,或者输入以逗号分隔的 Kafka 代理 URI 列表。每个 URI 的格式应为 host:port
  5. 对于 Transport Protocol 字段,请选择以下选项之一:

    • 如果要加密数据以便在传输中保护数据,请选择 TLS (传输层安全)。
    • 如果您不想加密您的数据,请选择 Plain,然后跳至第 7 步。
  6. 如果您在 Step 5 中选择了 TLS,然后在 Broker 证书 字段中粘贴 Kafka 代理的 PEM 证书文本。
  7. 单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息,指示验证是否成功。如果验证失败,请重新发布输入参数并重试。
  8. 如果验证成功,请单击 Next
  9. Name 字段中输入您选择的名称,可帮助您将这个连接与任何其他连接区分开来。例如,您可以输入 Kafka West
  10. Description 字段中,输入有助于了解此连接的任何信息。
  11. Save 查看您创建的连接现在可用。如果您输入了示例名称,您会看到 Kafka West 显示为可添加到集成的连接。