在即時中樞中新增 Amazon Managed Streaming for Apache Kafka （MSK） 作為來源

本文說明如何在 Fabric 實時中樞中，將適用於 Apache Kafka 的 Amazon Streaming （MSK） 新增為事件來源。

Amazon MSK Kafka 是完全受控的 Kafka 服務，可簡化設定、調整和管理。 藉由將 Amazon MSK Kafka 整合到事件串流中作為來源，您可以順暢地將 MSK Kafka 中的即時事件帶入，並加以處理，再將它們路由傳送至 Fabric 內的多個目的地。 

必要條件

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

資料來源頁面

1. 登入 Microsoft Fabric。

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

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

   

將適用於 Apache Kafka 的 Amazon 受控串流新增為來源

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

   

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

   

3. 在 [ 連線設定 ] 區段中，針對 [啟動程序伺服器] 輸入 Kafka 叢集的公用端點。

   

   若要取得公用端點：

   

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

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

5. 選取 Connect。 

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

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

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

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

   4. 針對 [安全性通訊協定]，預設值為 SASL_SSL。 默認 SASL 機制 為 SCRAM-SHA-512 ，無法變更。

      

7. 選取 [下一步]。 在 [ 檢閱 + 連線 ] 畫面上，檢閱摘要，然後選取 [ 連線]。

檢視資料流詳細數據

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

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

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

相關內容

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

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