在即時中樞中將 Apache Kafka 新增為來源 （預覽）

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

必要條件

• 在 Fabric 容量授權模式中存取工作區，或具有參與者或更高許可權的試用版授權模式。
• 執行中的 Apache Kafka 叢集。
• 您的 Apache Kafka 必須可公開存取，且不得位於防火牆後方或虛擬網路中受到保護。 

資料來源頁面

1. 登入 Microsoft Fabric。

2. 選取 左側導覽列上的 [即時 ]。

3. 在 [即時中樞] 頁面上，選取左側導覽功能表上 [聯機到] 底下的 [+ 數據源]。 您也可以選取右上角的 [+ 連接資料源] 按鈕，從 [所有數據流] 或 [我的數據流] 頁面取得 [數據源] 頁面。

   

將 Apache Kafka 新增為來源

1. 在 [ 選取數據源] 頁面上，選取 [Apache Kafka]。

   

2. 在連線頁面上，選取新增連線。

   

3. 在 [ 連線設定 ] 區段中，針對 [啟動程序伺服器]，輸入您的 Apache Kafka 伺服器位址。

   

4. 在 [連線認證] 區段中，如果您有 Apache Kafka 叢集的現有連線，請從 [連線] 下拉式清單中選取它。 否則，遵循下列步驟：

   1. 對於連線名稱 - 輸入連線的名稱。
   2. 針對 [ 驗證種類]，確認已 選取 [API 金鑰 ]。
   3. 針對 [ 金鑰 和 密碼]，輸入 API 金鑰和金鑰秘密。

5. 選取 Connect。 

6. 現在，在 [連線] 頁面上，遵循下列步驟。

   1. 針對 [主題]，輸入 Kafka 主題。

   2. 針對 [ 取用者群組]，輸入 Apache Kafka 叢集的取用者群組。 此欄位提供您取得事件的專用取用者群組。

   3. 選取 [ 重設自動位移 ]，以指定在沒有認可時開始讀取位移的位置。

   4. 針對 安全性通訊協議，預設值為 SASL_PLAINTEXT。

      注意

      Apache Kafka 來源目前僅支援 Apache Kafka 叢集與 Eventstream 之間的未加密數據傳輸（SASL_PLAINTEXT和 PLAINTEXT）。 即將推出透過 SSL 加密資料傳輸的支援。

   5. 除非另有設定，否則預設 SASL機制 通常是 PLAIN。 您可以選取 符合您安全性需求的 SCRAM-SHA-256 或 SCRAM-SHA-512 機制。

      

7. 選取 [下一步]。 在 [ 檢閱和建立] 畫面上檢閱摘要，然後選取 [ 新增]。

檢視資料流詳細數據

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

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

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

相關內容

若要瞭解如何取用資料流，請參閱下列文章：

• 處理資料流
• 分析資料流
• 設定資料流的警示