15.3. 将数据发布到 Kafka 代理


在集成中,您可以在流的中间发布数据到 Kafka 代理,或完成简单集成。要做到这一点,在流的中间或简单的集成完成连接中添加 Kafka 连接。

先决条件

  • 您创建了到 Kafka 代理的连接。
  • 您正在创建或编辑一个流,Fuse Online 正在提示您添加到集成中。或者,Fuse Online 提示您选择完成连接。

流程

  1. Add to Integration 页面中,点您要添加 Kafka 连接的加号。如果您要添加简单集成完成连接,请跳过这一步。
  2. 点击您要用来发布消息的 Kafka 连接。
  3. Choose an action 页面上,选择 Publish
  4. Topic Name 字段中,单击 carat 以显示主题列表,然后单击您要发布到的主题。
  5. Next 指定操作的输入类型。
  6. Select Type 字段中,如果数据类型不需要已知,接受 类型规格不需要,然后单击 Next。您不需要遵循其中一些说明的其余部分。

    但是,建议使用结构化数据类型。例如,如果您要在 data mapper 步骤中映射连接输入,则必须指定数据类型。数据映射程序无法显示非结构化数据的字段。

    要指定数据类型,请在 Select Type 字段中选择以下之一作为 schema 类型:

    • JSON 模式是描述 JSON 数据结构的文档。文档的介质类型是 application/schema+json
    • JSON 实例 是包含 JSON 数据的文档。文档的介质类型是 application/json
    • XML 模式是描述 XML 数据结构的文档。文档的文件扩展名是 .xsd
    • XML 实例 是包含 XML 数据的文档。文档的文件扩展名是 .xml
    • CSV 实例 是一个包含以逗号分隔的值(CSV)数据的文档。文档的文件扩展名是 .csv
  7. Definition 输入框中,粘贴符合您选择的模式类型的定义。例如,如果您选择 JSON 模式,则会粘贴 JSON 架构文件的内容,该文件具有介质类型 application/schema+json
  8. Data Type Name 字段中输入您为数据类型选择的名称。例如,如果您要为供应商指定 JSON 模式,则可能会将 Vendor 指定为数据类型名称。

    当您创建或编辑使用您要为其指定此类型的连接的集成时,您将看到此数据类型名称。Fuse Online 在集成视觉化和 data mapper 中显示类型名称。

  9. Data Type Description 字段中,提供可帮助您区分此类型的信息。当您将鼠标悬停在处理此类型的步骤上时,这个描述会出现在 data mapper 中。
  10. 点击 Next

结果

这个连接会出现在您添加的集成视觉化中。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat