15.3. 将数据发布到 Kafka 代理


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

先决条件

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

流程

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

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

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

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

    在创建或编辑使用指定此类型的连接时,您将看到此数据类型名称。Fuse Online 在集成视觉化和数据映射程序中显示类型名称。

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

结果

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

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.