15.2. 创建到 Kafka 代理的连接
在集成中,若要从 Kafka 主题订阅数据或将数据发布到 Kafka 主题,请创建一个到 Kafka 的连接,然后将该连接添加到集成。
先决条件
- 您可以在集群中启用了 Kafka 代理的自动发现,如 启用 Kafka 代理/AMQ Streams 的自动发现 中所述。或者,您知道您要连接的 Kafka 代理的 URI。
- 如果要使用传输层安全(TLS)加密数据,则具有 Kafka 代理的 PEM 证书文本。通常,您可以从 Kafka 服务器管理员获取代理证书文本。
流程
- 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示任何可用连接。
- 点 Create Connection 以显示连接器。
- 点 Kafka Message Broker 连接器。
- 在 Kafka broker URIs 字段中,选择您希望此连接访问的代理,或者输入以逗号分隔的 Kafka 代理 URI 列表。每个 URI 的格式应为 host:port。
对于 Transport Protocol 字段,请选择以下选项之一:
- 如果要加密数据以便在传输中保护数据,请选择 TLS (传输层安全)。
- 如果您不想加密您的数据,请选择 Plain,然后跳至第 7 步。
- 如果您在 Step 5 中选择了 TLS,然后在 Broker 证书 字段中粘贴 Kafka 代理的 PEM 证书文本。
- 单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息,指示验证是否成功。如果验证失败,请重新发布输入参数并重试。
- 如果验证成功,请单击 Next。
-
在 Name 字段中输入您选择的名称,可帮助您将这个连接与任何其他连接区分开来。例如,您可以输入
Kafka West。 - 在 Description 字段中,输入有助于了解此连接的任何信息。
- 点 Save 查看您创建的连接现在可用。如果您输入了示例名称,您会看到 Kafka West 显示为可添加到集成的连接。