通过

将 Amazon MSK Kafka 源添加到事件流（预览版）

  • 项目

本文介绍如何将 Amazon MSK Kafka 源添加到事件流。 

Amazon MSK Kafka 是一种完全托管的 Kafka 服务，可简化设置、缩放和管理。 通过将 Amazon MSK Kafka 作为事件流中的源集成，可以无缝地将 MSK Kafka 中的实时事件引入其中，并在将其路由到 Fabric 中的多个目标之前对其进行处理。 

重要

Fabric 事件流的增强功能目前以预览版方式提供。

注意

工作区容量的以下区域不支持此源：美国西部 3、瑞士西部。

先决条件

  • 有权访问具有参与者或更高权限的 Fabric 高级工作区。
  • 处于活动状态的 Amazon MSK Kafka 群集。
  • Amazon MSK Kafka 群集必须可公开访问，并且不能位于防火墙后面或在虚拟网络中受到保护。 

注意

一个事件流的源和目标的最大数量为 11。

将 Amazon MSK Kafka 添加为源

  1. 创建启用了增强功能（预览）选项的事件流。
  2. 在下一个屏幕上，选择“添加外部源”。

配置并连接到 Amazon MSK Kafka

  1. 在 “选择数据源 ”页上，选择 Amazon MSK Kafka。

    显示选择 Amazon MSK Kafka 作为“获取事件”向导中的源类型的屏幕截图。

  2. 在“连接”页上，选择“新建连接”。

    显示在“获取事件”向导的“连接”页上选择“新建连接”链接的屏幕截图。

  3. 在 “连接设置” 部分中，对于 Bootstrap 服务器，输入 Kafka 群集的公共终结点。

    显示“获取事件”向导的“连接”页上的 Bootstrap 服务器字段选择的屏幕截图。

    若要获取公共终结点，请执行以下操作：

    显示 Amazon MSK 群集的公共终结点的屏幕截图。

  4. 在“连接凭据”部分中，如果有与 Amazon MSK Kafka 群集的现有连接，请从“连接”下拉列表中选择它。 否则，请执行以下步骤：

    1. 对于“连接名称”，为连接输入名称。
    2. 对于 身份验证类型，请确认已 选择 API 密钥 。
    3. 对于 密钥 和 机密，请输入 Amazon MSK Kafka 群集的 API 密钥和密钥机密。

  5. 选择“连接” 。 

  6. 现在，在“连接”页上，按照以下步骤操作。

    1. 对于 主题，请输入 Kafka 主题。

    2. 对于 使用者组，请输入 Kafka 群集的使用者组。 此字段提供用于获取事件的专用使用者组。

    3. 选择“ 重置自动偏移 ”以指定在没有提交的情况下开始读取偏移的位置。

    4. 对于 安全协议，默认值 为SASL_SSL。 默认 SASL 机制 为 SCRAM-SHA-512 ，无法更改。

      显示 Amazon MSK Kafka 连接设置的第一页的屏幕截图。

  7. 选择下一步。 在“查看并创建”屏幕上，查看摘要，然后选择“添加”。

可以在“编辑”模式下看到添加到事件流的 Amazon MSK Kafka 源。 

显示 Amazon MSK Kafka 源在“编辑”视图中的屏幕截图。

完成这些步骤后，Amazon MSK Kafka 源可用于实时视图中的可视化效果。

显示 Live 视图中 Amazon MSK Kafka 源的屏幕截图。

相关内容

其他连接器：