共用方式為


將 Confluent Kafka 來源新增至事件串流 (預覽)

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

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

重要

Fabric 事件數據流的增強功能目前為預覽狀態。

注意

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

必要條件

  • 具有參與者或更高許可權的網狀架構進階工作區存取權。
  • Confluent Cloud Kafka 叢集和 API 密鑰。
  • 您的 Confluent Cloud Kafka 叢集必須可公開存取,且不得位於防火牆後方或虛擬網路中受到保護。

注意

一個事件數據流的來源和目的地數目上限為 11

將 Confluent Cloud Kafka 新增為來源

  1. 使用選取預覽切換來建立 eventstream。
  2. 選取 [ 新增外部來源]。

設定並連線到 Confluent Kafka

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

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

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

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

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

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

    1. 針對 [ 連線名稱],輸入連接的名稱。
    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. 選取 [下一步]。 在 [ 檢閱和建立] 畫面上檢閱摘要,然後選取 [ 新增]。

您會看到 Confluent Cloud Kafka 來源會在 [編輯] 模式的畫布上新增至您的事件串流。 若要實作這個新增的 Confluent Cloud Kafka 來源,請選取功能區上的 [ 發佈 ]。

顯示 [編輯] 檢視中 Confluent Kafka 來源的螢幕快照。

完成這些步驟之後,Confluent Cloud Kafka 來源就可用於即時檢視中的視覺效果。

顯示 Live 檢視中 Confluent Kafka 來源的螢幕快照。

其他連接器: