外掛程式 - Amazon Managed Streaming for Apache Kafka

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

外掛程式

外掛程式是包含定義連接器邏輯的程式碼的 AWS 資源。您可以將 JAR 檔案 (或包含一個或多個 JAR 檔案的 ZIP 檔案) 上傳至 S3 儲存貯體,並在建立外掛程式時指定儲存貯體的位置。在建立連接器時,您可以指定要讓 MSK Connect 用於連接器的外掛程式。插件與連接器的關係是 one-to-many:您可以從同一個插件創建一個或多個連接器。

如需如何開發連接器程式碼的相關資訊,請參閱 Apache Kafka 文件中的 Connector Development Guide

使用建立自訂外掛程式 AWS Management Console
  1. 開啟位於 https://console.aws.amazon.com/msk/ 的 Amazon MSK 主控台。

  2. 在左窗格的 MSK Connect 下選擇自訂外掛程式

  3. 選擇建立自訂外掛程式

  4. 選擇 Browse S3 (瀏覽 S3)。

  5. 在 S3 儲存貯體清單中,為外掛程式選擇具有 JAR 或 ZIP 檔案的儲存貯體。

  6. 在物件清單中,為外掛程式選取 JAR 或 ZIP 檔案左邊的方塊,然後選擇選擇

  7. 選擇建立自訂外掛程式

若要使用 MSK Connect API 建立自訂外掛程式,請參閱CreateCustomPlugin