通过

在 Fabric Real-Time 中心添加 Apache Kafka 作为源（预览版）

本文介绍如何将 Apache Kafka 添加为 Fabric 实时中心的事件源。

先决条件

  • 在 Fabric 容量许可证模式或具有参与者或更高权限的试用许可证模式下访问工作区。
  • 正在运行的 Apache Kafka 群集。
  • Apache Kafka 必须可供公开访问，并且不能位于防火墙后面或在虚拟网络中受到保护。 

数据源页面

  1. 登录 Microsoft Fabric。

  2. 如果页面左下角显示“Power BI”，依次选择“Power BI”、“Fabric”，以切换到 Fabric 工作负载。

    显示如何切换到 Fabric 工作负荷的屏幕截图。

  3. 选择左侧导航栏上的“实时”。

    显示如何启动“连接到数据源”体验的屏幕截图。

  4. 在“实时中心”页上，选择左侧导航菜单上“连接到”下的“+ 数据源”。

    显示 Real-Time 中心的“数据源”页的屏幕截图。

    还可以通过选择右上角的“+ 添加数据”按钮，从 Real-Time 中心页面访问“数据源”页。

    显示“连接数据源”按钮的屏幕截图。

将 Apache Kafka 添加为源

在 “数据源 ”页上，选择 “Apache Kafka”。

选择 Apache Kafka 的屏幕截图。

配置 Apache Kafka 连接器

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

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

  2. 在“连接设置”部分中，针对“启动服务器”输入你的 Apache Kafka 服务器地址。

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

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

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

  4. 选择“连接” 。 

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

    1. 对于“主题”，输入 Kafka 主题。

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

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

    4. 对于新添加的 Apache Kafka 源，唯一支持的安全协议是SASL_SSL。 使用 SASL_SSL时，服务器证书必须由 受信任的 CA 列表中包括的证书颁发机构（CA）签名。

    5. 默认的 SASL 机制通常是 PLAIN，除非另有配置。 可以选择符合你的安全要求的 SCRAM-SHA-256 或 SCRAM-SHA-512 机制。

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

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

查看数据流详细信息

  1. 在“查看 + 连接”页上，如果选择“打开事件流”，向导会打开使用选定的 Apache Kafka 源为你创建的事件流。 要关闭向导，请选择页面底部的“关闭”。
  2. 应在Real-Time 中心主页的最近流式数据部分看到该流。 有关详细步骤，请参阅在 Fabric 实时中心查看数据流的详细信息。

相关内容

若要了解有关使用数据流的信息，请参阅以下文章：