14.2. 创建到 Kafka 代理的连接

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

重要

在这个发行版本中，到 Kafka 的连接不支持 SSL。预计会在以后的版本中有所变化。

先决条件

流程

在 Fuse Online 中，在左侧面板中，单击 Connections 以显示任何可用连接。
在右上角，单击 Create Connection 以显示连接器。
点 Kafka 连接器。
在 Kafka broker URIs 字段中，选择您希望此连接访问的代理，或者输入以逗号分隔的 Kafka 代理 URI 列表。每个 URI 的格式应为 host:port。
单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息，指示验证是否成功。如果验证失败，请重新发布输入参数并重试。
如果验证成功，请单击 Next。
在 Name 字段中输入您选择的名称，可帮助您将这个连接与任何其他连接区分开来。例如，您可以输入 Kafka West。
在 Description 字段中，输入有助于了解此连接的任何信息。
点 Save 查看您创建的连接现在可用。如果您输入了示例名称，您会看到 Kafka West 显示为可添加到集成的连接。

返回顶部