查看 Application Integration 支援的連接器。
Apache Kafka 觸發條件
Apache Kafka 觸發程序是 Connector Event 觸發程序,可讓您根據在 Apache Kafka 連線中訂閱的 Apache Kafka 事件,叫用整合。
事前準備
如要為 Apache Kafka 觸發程序建立或設定新連線,請確認您在專案中具備下列 Identity and Access Management (IAM) 角色:
- 連接器管理員 (
roles/connectors.admin
)
如要瞭解如何授予角色,請參閱「管理存取權」。
將下列 IAM 角色授予要用於 Apache Kafka 觸發程序的服務帳戶:
- Application Integration 叫用者 (
roles/integrations.integrationInvoker
)
如要瞭解如何將角色授予服務帳戶,請參閱「管理服務帳戶的存取權」一文。
限制
Apache Kafka 觸發程序有下列限制:
- 不支援使用私有信任儲存區的事件訂閱項目
SASL_SSL
安全通訊協定。 - 不支援事件訂閱的
mTLS
。
新增 Apache Kafka 觸發條件
如要將 Apache Kafka 觸發條件新增至整合服務,請按照下列步驟操作:
- 前往 Google Cloud 控制台的「Application Integration」頁面。
- 在導覽選單中,按一下「整合」
系統隨即會顯示「整合清單」頁面,列出 Google Cloud 專案中可用的所有整合功能。
- 選取現有整合,或按一下「建立整合」建立新整合。
如要建立新的整合項目:
- 在「建立整合」窗格中輸入名稱和說明。
- 選取整合作業的區域。
- 選取整合的服務帳戶。如要變更或更新整合的服務帳戶詳細資料,請隨時前往整合工具列的「整合摘要」 窗格。
- 點選「建立」。
新建立的整合服務會在整合服務編輯器中開啟。
- 在整合編輯器的導覽列中,按一下「觸發條件」,即可查看可用觸發條件的清單。
- 在整合服務編輯器中,按一下並放置「Apache Kafka trigger」(Apache Kafka 觸發條件) 元素。
如要設定 Apache Kafka 觸發程序,您可以使用 Integration Connectors 中現有的 Apache Kafka 連線,也可以使用內嵌連線建立選項建立新的 Apache Kafka 連線。
使用現有連線設定 Apache Kafka 觸發條件
您可以使用 Integration Connectors 中的現有 Apache Kafka 連線,設定 Apache Kafka 觸發程序。請注意,Apache Kafka 觸發程序是連接器事件觸發程序,因此您只能使用已啟用事件訂閱功能的 Apache Kafka 連線來設定觸發程序。
如要瞭解如何使用新的 Apache Kafka 連線設定 Apache Kafka 觸發程序,請參閱「使用新連線設定 Apache Kafka 觸發程序」一文。
如要使用現有的 Apache Kafka 連線設定 Apache Kafka 觸發程序,請按照下列步驟操作:
- 按一下整合服務編輯器中的「Apache Kafka trigger」(Apache Kafka 觸發條件) 元素,開啟觸發條件設定窗格。
- 按一下「設定觸發條件」。
- 在「連接器事件觸發條件編輯器」頁面中,提供下列設定詳細資料:
- 區域:選取 Apache Kafka 連線的區域。
- 連線:選取要使用的 Apache Kafka 連線。
應用程式整合只會顯示已啟用事件訂閱的有效 Apache Kafka 連線。
- 主題名稱:輸入主題名稱。
- 消費者群組 ID:視需要輸入消費者群組 ID,指定 Kafka 消費者所屬的消費者群組名稱。
- 分區:如要訂閱特定分區,請輸入分區。分區可將主題劃分成多個部分,並將每個部分儲存在叢集中的不同節點。
- 初始偏移:選取偏移重設策略:
- 如果選取「最早」,連線會消耗未消耗的訊息,包括在消費者群組生命週期之前產生的任何訊息。
- 如果選取「最新」,連線會取用在建立消費者群組後產生的訊息。
- 服務帳戶:選取具有 Apache Kafka 觸發程序必要 IAM 角色的服務帳戶。
- 按一下 [完成]。
使用新連線設定 Apache Kafka 觸發條件
如要使用新的 Apache Kafka 連線設定 Apache Kafka 觸發程序,請按照下列步驟操作:
- 按一下整合服務編輯器中的「Apache Kafka trigger」(Apache Kafka 觸發條件) 元素,開啟觸發條件設定窗格。
- 按一下「設定 Apache Kafka 觸發條件」。
- 略過「區域」欄位。
- 按一下「連線」,然後從清單中選取「建立連線」選項。「建立連線」窗格隨即顯示。
- 在「位置」步驟中,選擇新 Apache Kafka 連線的位置:
- 「Region」(地區):從清單中選取地區。
- 點選「下一步」。
- 在「連線詳細資料」步驟中,提供新的 Apache Kafka 連線詳細資料:
- 連接器版本:從清單中選擇可用的 Apache Kafka 連接器版本。
- 連線名稱:輸入 Apache Kafka 連線的名稱。
- (選用) 說明: 輸入連線說明。
- (選用) 啟用 Cloud Logging:選取這個核取方塊,即可儲存連線的所有記錄資料。
- 服務帳戶:選取具有 Apache Kafka 連線必要 IAM 角色的服務帳戶。
- 系統預設會為 Apache Kafka 連線選取「啟用事件訂閱、實體和動作」選項。
- 類型偵測配置: 選取
MessageOnly
。 - 登錄服務:用於處理主題結構定義的結構定義登錄服務。
- 登錄類型:為特定主題指定的結構定義類型。
-
登錄版本:從指定主題的
RegistryUrl
讀取的結構定義版本。 -
登錄使用者:使用者名稱或存取金鑰值,用於向
RegistryUrl
中指定的伺服器授權。 -
登錄密碼:Secret Manager 密鑰,內含密碼/密鑰值,可授權存取
RegistryUrl
中指定的伺服器。 - 視需要設定「連線節點設定」:
- 節點數量下限:輸入連線節點數量下限。
- 節點數量上限:輸入連線節點數量上限。
節點是用來處理交易的連線單位 (或備用資源)。連線處理的交易量越多,就需要越多節點;反之,處理的交易量越少,需要的節點就越少。如要瞭解節點對連接器定價的影響,請參閱「 連線節點定價」。如未輸入任何值,系統預設會將節點下限設為 2 (提高可用性),節點上限則設為 50。
- (選用) 按一下「+ 新增標籤」,以鍵/值組合的形式為連線新增標籤。
- 啟用 SSL:這個欄位會設定是否啟用 SSL。
- 點選「下一步」。
- 在「目的地」部分,輸入要連線的 Kafka 啟動伺服器詳細資料。
- 目的地類型:選取目的地類型。
- 如要指定目的地主機名稱或 IP 位址,請選取「主機地址」,然後在「主機 1」欄位中輸入地址。
- 如要建立私人連線,請選取「Endpoint attachment」(端點連結),然後從「Endpoint Attachment」(端點連結) 清單中選擇所需連結。
如要建立與後端系統的公開連線,並加強安全性,建議為連線設定靜態輸出 IP 位址,然後設定防火牆規則,只允許特定靜態 IP 位址。
如要指定其他 Kafka 啟動伺服器,請按一下「+ 新增目的地」。
- 點選「下一步」。
- 目的地類型:選取目的地類型。
-
在「Authentication」(驗證) 部分中,輸入驗證詳細資料。
- 選取「驗證類型」並輸入相關詳細資料。
Apache Kafka 連線支援下列驗證類型:
-
使用者名稱和密碼
- 使用者名稱:用於連線的 Apache Kafka 使用者名稱。
- 密碼:Secret Manager 密鑰,內含與 Apache Kafka 使用者名稱相關聯的密碼。
- 驗證配置:用於驗證的配置。
Apache Kafka 連線支援下列驗證機制:
- Plain
- SCRAM-SHA-1
- SCRAM-SHA-256
-
不適用
如要使用匿名登入,請選取「不適用」。
-
使用者名稱和密碼
- 點選「下一步」。
- 選取「驗證類型」並輸入相關詳細資料。
- 輸入無法傳送郵件的設定。如果設定無效信件,連線會將未處理的事件寫入指定的 Pub/Sub 主題。輸入下列詳細資料:
- 無法傳送的訊息專案 ID: 您已設定無法傳送的訊息 Pub/Sub 主題的 Google Cloud 專案 ID。
- 無效信件主題: 要寫入未處理事件詳細資料的 Pub/Sub 主題。
- 點選「下一步」。
- 檢查:檢查連線和驗證詳細資料。
- 點選「建立」。
觸發輸出
Apache Kafka 觸發程序需要幾分鐘才能完成事件訂閱設定。您可以在「事件訂閱詳細資料」下方的觸發條件設定窗格中,查看事件訂閱狀態。
Apache Kafka 觸發程序會使用下列狀態,指出事件訂閱的狀態:
Creating
:表示觸發條件正在訂閱事件訂閱項目。Active
:表示觸發條件已成功訂閱事件訂閱項目。Error
:表示設定的事件訂閱項目有問題。
除了事件訂閱狀態,「事件訂閱詳細資料」部分也會顯示其他詳細資料,例如連線區域、連線名稱和事件訂閱名稱。
觸發條件輸出變數
針對每個事件,Apache Kafka 觸發程序會產生 ConnectorEventPayload
輸出變數 (JSON 格式),您可以在下游工作中使用。輸出變數會包含 Apache Kafka 事件的酬載。例如:
{ "message": "{\"key\":\"18\",\"topic\":\"test\",\"value\":\"hello world\",\"partition\":0,\"offset\":12,\"headers\":\"{}\",\"timestamp\":1712755076824,\"serializedMessagesize\":14}", "contentType": "text/plain" }
查看事件訂閱項目
如要查看及管理與 Integration Connectors 中連線相關聯的所有事件訂閱項目,請按照下列步驟操作:
- 前往「整合連接器」>「連線」頁面。
- 按一下要查看訂閱項目的連結。
- 按一下「事件訂閱」分頁標籤。
系統會顯示連線的所有事件訂閱項目。
編輯 Apache Kafka 觸發條件
您可以編輯 Apache Kafka 觸發程序,變更或更新連線設定和事件訂閱詳細資料。
如要編輯 Apache Kafka 觸發條件,請執行下列步驟:
- 按一下整合服務編輯器中的「Apache Kafka trigger」(Apache Kafka 觸發條件) 元素,開啟觸發條件設定窗格。
- 按一下「設定 Apache Kafka 觸發條件」。
- 在「Connector Event Trigger Editor」(連接器事件觸發條件編輯器) 頁面中執行下列操作:
- 如要保留先前設定的事件訂閱項目,請按一下「保留」,否則請按一下「刪除」。
- 視需要更新連線設定和事件訂閱詳細資料。
- 按一下 [完成]。
您可以在「事件訂閱詳細資料」下方的觸發條件設定窗格中,查看更新後的連線和事件訂閱詳細資料。
配額與限制
如要瞭解配額和限制,請參閱配額和限制。