將 Confluent Kafka 來源新增至 eventstream

發行項
11/19/2024

本文說明如何將 Confluent Kafka 來源新增至事件串流。

Confluent Cloud Kafka 是一個串流平臺，使用 Apache Kafka 提供功能強大的資料流和處理功能。藉由整合 Confluent Cloud Kafka 為 Eventstream 中的來源，您就可以順暢地處理即時資料流，再將它們路由至 Fabric 內的多個目的地。

注意

工作區容量的下列區域不支援此來源： 美國西部 3、 瑞士西部。

必要條件

在 Fabric 容量授權模式中存取工作區，或具有參與者或更高許可權的試用版授權模式。
Confluent Cloud Kafka 叢集和 API 密鑰。
您的 Confluent Cloud Kafka 叢集必須可公開存取，且不得位於防火牆後方或在虛擬網路中受到保護。
如果您沒有 eventstream，請建立 eventstream。

啟動選取數據源精靈

如果您尚未將任何來源新增至事件串流，請選取 [ 使用外部來源 ] 圖格。

如果您要將來源新增至已發行的事件串流，請切換至 [編輯 模式]，選取 功能區上的 [新增來源 ]，然後選取 [ 外部來源]。

設定並連線到 Confluent Kafka

在 [ 選取數據源] 頁面上，選取 [ Confluent]。
若要建立 Confluent Cloud Kafka 來源的連線，請選取 [ 新增連線]。
在 [ 連線設定 ] 區段中，輸入 Confluent Bootstrap Server。流覽至您的 Confluent Cloud 首頁，選取 [ 叢集設定]，然後將位址複製到您的 Bootstrap 伺服器。
在 [連線認證] 區段中，如果您有 Confluent 叢集的現有連線，請從 [連線] 下拉式清單中選取它。否則，遵循下列步驟：
1. 對於連線名稱 - 輸入連線的名稱。
2. 針對 [驗證種類]，確認已 選取 [Confluent 雲端密鑰 ]。
3. 針對 API 金鑰 和 API 金鑰秘密：
  1. 流覽至您的 Confluent Cloud。
  2. 選取左側功能表上的 [金鑰]。
  3. 選取 [新增] 按鈕以建立新規則。
  4. 複製 API 金鑰和祕密金鑰。
  5. 將這些值貼到 [API 金鑰 ] 和 [API 金鑰秘密 ] 字段中。
  6. 選取連線
捲動以查看頁面上的 [設定 Confluent 數據源 ] 區段。輸入資訊以完成 Confluent 數據源的設定。
1. 針對 [ 主題]，輸入 Confluent Cloud 的主題名稱。您可以在 Confluent Cloud Console 中建立或管理您的主題。
2. 針對 [ 取用者群組]，輸入 Confluent Cloud 的取用者群組。它提供您專用的取用者群組，以從 Confluent Cloud 叢集取得事件。
3. 針對 [ 重設自動位移 ] 設定，選取下列其中一個值：
  - 最早 – Confluent 叢集中最早可用的數據
  - 最新 - 最新的可用數據
  - 無 – 不會自動設定位移。
選取 [下一步]。在 [ 檢閱和建立] 畫面上檢閱摘要，然後選取 [ 新增]。