15.2. 从 Kafka 代理获取数据以触发集成执行

流程

1. 在左侧的 Fuse Online 面板中，单击 Integrations。
2. 点 Create Integration。
3. 在 Choose a connection 页面中，点您要用来开始集成的 Kafka 连接。
4. 在 Choose a action 页面中，选择 Subscribe action 以接收来自您指定的主题中的数据。
5. 在 Topic Name 字段中，单击 carat 以显示主题列表，然后单击您要订阅的主题。或者，键入主题名称来创建该主题。
6. 点 Next 指定操作的输出类型。

7. 在 Select Type 字段中，如果数据类型不需要已知，接受 类型规格不需要，然后单击 Next。您不需要遵循其中一些说明的其余部分。

   但是，建议使用结构化数据类型。例如，如果要将 Kafka 连接输出映射到后续步骤，则必须指定数据类型。数据映射程序无法识别非结构化数据。

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

   • JSON 模式是描述 JSON 数据结构的文档。文档的介质类型是 application/schema+json。
   • JSON 实例 是包含 JSON 数据的文档。文档的介质类型是 application/json。
   • XML 模式是描述 XML 数据结构的文档。文档的文件扩展名是 .xsd。
   • XML 实例 是包含 XML 数据的文档。文档的文件扩展名是 .xml。
   • CSV 实例 是一个包含以逗号分隔的值(CSV)数据的文档。文档的文件扩展名是 .csv。
8. 在 Definition 输入框中，粘贴符合您选择的模式类型的定义。例如，如果您选择 JSON 模式，则会粘贴 JSON 架构文件的内容，该文件具有介质类型 application/schema+json。

9. 在 Data Type Name 字段中输入您为数据类型选择的名称。例如，如果您要为供应商指定 JSON 模式，则可能会将 Vendor 指定为数据类型名称。

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

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