建立自訂外掛程式 - Amazon Managed Streaming for Apache Kafka

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

建立自訂外掛程式

外掛程式是一種 AWS 資源，其中包含定義連接器邏輯的程式碼。您可以將 JAR 檔案 (或包含一個或多個 JAR 檔案的 ZIP 檔案) 上傳至 S3 儲存貯體，並在建立外掛程式時指定儲存貯體的位置。建立外掛程式時，MSK Connect 會在該時間點複製 S3 物件的內容。它不會維護 S3 物件的連結，因此對物件的任何後續修改都不會影響外掛程式或其連接器。在建立連接器時，您可以指定要讓 MSK Connect 用於連接器的外掛程式。外掛程式與連接器的關係是one-to-many：您可以從相同的外掛程式建立一個或多個連接器。

注意

自訂外掛程式無法正確更新。若要使用新版本的外掛程式程式碼，請刪除參考外掛程式的所有連接器、刪除外掛程式，然後重新建立。

自訂外掛程式的相依性封裝

我們建議您包含外掛程式的所有必要 JAR 檔案和相依性。將您的連接器封裝為下列其中一項：

  • 包含外掛程式所有必要 JAR 檔案和相依性的 ZIP 檔案。

  • 單一 uber JAR，其中包含外掛程式及其相依性的所有類別檔案。

未綁定您的外掛程式相依性可能會影響執行時間環境中的可用性或相容性，並導致非預期的錯誤。

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

使用 建立自訂外掛程式 AWS 管理主控台

  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。