共用方式為


在即時中樞中將 Confluent Cloud Kafka 新增為來源 (預覽)

本文說明如何在 Fabric 實時中樞中將 Confluent Cloud Kafka 新增為事件來源。

注意

實時中樞目前為預覽狀態。

必要條件

  • 取得具有參與者或更高許可權的網狀架構進階工作區的存取權。
  • Confluent Cloud Kafka 叢集和 API 密鑰。

啟動取得事件體驗

  1. 切換至 Microsoft Fabric 中的即時智能體驗。 選取 左側導覽列上的 [Microsoft Fabric ],然後選取 [ 即時智慧]。

    顯示如何切換至即時智慧體驗的螢幕快照。

  2. 選取 左側導覽列上的 [實時中樞 ]。

    顯示如何在 Microsoft Fabric 中啟動即時中樞的螢幕快照。

  3. 在 [ 即時中樞 ] 頁面上,選取 頁面右上角的 [+ 取得事件 ]。

    顯示 [即時中樞] 中 [取得事件] 按鈕選取項目的螢幕快照。

將 Confluent Cloud Kafka 新增為來源

  1. 在 [ 選取數據源] 頁面上,選取 [ Confluent]。

    顯示選取 Confluent 做為 [取得事件精靈] 中來源類型的螢幕快照。

  2. 若要建立 Confluent Cloud Kafka 來源的連線,請選取 [ 新增連線]。

    顯示 [取得事件精靈] 連線 頁面上 [新增連線] 鏈接選取項目的螢幕快照。

  3. [連線 ion 設定] 區段中,輸入 Confluent Bootstrap Server。 流覽至您的 Confluent Cloud 首頁,選取 [叢集 設定],然後將位址複製到您的 Bootstrap 伺服器。

  4. [連線 ion 認證] 區段中,如果您有 Confluent 叢集的現有連線,請從下拉式清單中選取它以取得 連線。 否則,遵循下列步驟:

    1. 針對 連線 ion 名稱,輸入連線的名稱。
    2. 針對 [驗證種類],確認已 選取 [Confluent 雲端密鑰 ]。
    3. 針對 API 金鑰API 金鑰秘密
      1. 流覽至您的 Confluent Cloud。

      2. 選取 側邊功能表上的 [API 金鑰 ]。

      3. 選取 [ 新增金鑰 ] 按鈕以建立新的 API 金鑰。

      4. 複製 API 金鑰秘密

      5. 將這些值貼到 [API 金鑰 ] 和 [API 金鑰秘密 ] 字段中。

      6. 選取連線

        顯示 Confluent 連線設定第一頁的螢幕快照。

  5. 捲動以查看頁面上的 [設定 Confluent 數據源 ] 區段。 輸入資訊以完成 Confluent 數據源的設定。

    1. 針對 [ 主題],輸入 Confluent Cloud 的主題名稱。 您可以在 Confluent Cloud Console 中建立或管理您的主題。
    2. 針對 [ 取用者群組],輸入 Confluent Cloud 的取用者群組。 它提供您專用的取用者群組,以從 Confluent Cloud 叢集取得事件。
    3. 針對 [ 重設自動位移 ] 設定,選取下列其中一個值:
      • 最早 – Confluent 叢集中最早可用的數據

      • 最新 - 最新的可用數據

      • – 不會自動設定位移。

        顯示第二頁 - 設定 Confluent 數據源頁面 - Confluent 連線設定的螢幕快照。

  6. 在右窗格的 [ 串流詳細數據 ] 區段中,執行下列步驟:

    1. 選取您要儲存連線的工作區

    2. 輸入要為您建立之 eventstream 的名稱。

    3. 系統會自動為您產生即時中樞的 數據流 名稱。

      顯示 [Confluent 連線設定] 頁面 [串流詳細數據] 區段之右窗格的螢幕快照。

  7. 選取 [下一步]。

  8. 在 [ 檢閱和建立] 畫面上檢閱摘要,然後選取 [ 建立來源]。

檢視數據流詳細數據

  1. 在 [ 檢閱並建立 ] 頁面上,如果您選取 [開啟事件串流],精靈會使用選取的 Confluent Cloud Kafka 來源開啟它為您建立的事件串流。 若要關閉精靈,請選取 頁面底部的 [關閉 ]。

  2. 在 [實時中樞] 中,切換至 [即時中樞] 的 [數據流] 索引 標籤。 重新整理頁面。 您應該會看到為您建立的數據流。

    如需詳細步驟,請參閱 在網狀架構即時中樞中檢視數據流的詳細數據。

若要瞭解如何取用數據流,請參閱下列文章: