第 14 章连接到 Kafka

Apache Kafka 是一个分布式流平台，可用于获取和发布数据。在集成中，您可以从您指定的 Kafka 主题订阅数据，或将数据发布到您指定的 Kafka 主题。要做到这一点，创建一个到 Kafka 的连接，然后将该连接添加到集成流中。详情包括在以下主题中：

14.1. 创建到 Kafka 代理的连接
复制链接

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

重要

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

前提条件

您必须知道您要连接的 Kafka 代理的 URI。

流程

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