第 15 章 连接到 Kafka

流程

1. 在 Fuse Online 中，在左侧面板中，单击 Connections 以显示任何可用的连接。
2. 点击 Create Connection 以显示连接器。
3. 点 Kafka Message Broker 连接器。

4. 在 Kafka 代理 URIs 字段中，键入或选择您希望此连接访问的代理，或者输入以逗号分隔的 Kafka 代理 URI 列表。每个 URI 应采用 host:port 的形式。

   对于 Red Hat Managed Kafka，输入 Managed Kafka 实例 Bootstrap 服务器 URI。请注意，如果您在 OpenShift 集群上安装了 Strimzi Operator 或 AMQ Streams Operator，则 URI 会被自动发现，您可以选择它。

5. 对于 Security Protocol 字段，选择以下选项之一：

   • 如果要加密数据以在传输中保护，请选择 TLS （端口层安全性）。跳至第 7 步。
   • 如果要使用 SASL 验证并使用 SSL 加密您的数据（例如，在 Red Hat Managed Kafka 中），请选择 SASL_SSL。
   • 如果您不想加密数据，请选择 Plain，然后跳至第 8 步。

6. 如果您选择了 SASL_SSL 作为安全协议，则需要选择两个选项来设置凭证：

   • 如果要使用 PLAIN 作为 SASL 机制，则必须设置 Username 和 Password 字段。

   • 如果要使用 OAUTHBEARER 作为 SASL 机制，则必须设置以下字段：

     • 带有 OAuth 客户端的用户名。
     • 使用 OAUth 客户端 Secret 密码。

     • SASL 登录回调处理程序 类，您可以使用来自 kafka-clients 2.5 版本或 Strimzi 项目中的 kafka-oauth-client 的所有回调处理程序类。要连接到 Red Hat Managed Kafka，您可以使用：

       io.strimzi.kafka.oauth.client.JaasClientOauthLoginCallbackHandler

     • 带有由您的供应商提供的 /oauth/token endpoint URI 的 OAuth 令牌端点 URI。
7. 如果您在第 5 步中选择了 TLS，然后在 Broker 证书 字段中粘贴 Kafka 代理的 PEM 证书文本。

8. 可选。点 Add a custom 属性指定 key:value 对，以配置 Kafka producer 和使用者选项。

   例如，如果您希望新集成消耗来自主题的旧消息，请将 auto.offset.reset 值从默认值（最新的）更改为最早的，方法是输入 auto.offset.reset for the Key 字段，并在 Value 字段中键入 earlie st 。

   有关 Kafka producer 配置选项的详情，请访问 https://kafka.apache.org/documentation/#producerconfigs

   有关 Kafka consumer 配置选项的详情，请访问 https://kafka.apache.org/documentation/#consumerconfigs

   注意： 如果您添加配置属性，Fuse Online 不会将它们包含在下一步中，作为其验证过程的一部分。

9. 单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息，指示验证是否成功。如果验证失败，请调整输入参数并重试。
10. 如果验证成功，点 下一步。
11. 在 Name 字段中输入您的选择的名称，帮助您将这个连接与任何其他连接区分开来。例如，您可以键入 Kafka Test。
12. 在 Description 字段中输入任何有助于了解这个连接的信息。
13. 点 Save 以查看您创建的连接现在可用。如果您输入了示例名称，您会看到 Kafka Test 显示为您可以选择添加到集成的连接。