本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
创建自定义插件
插件是一种 Amazon 资源,其中包含定义连接器逻辑的代码。您可以将 JAR 文件(或包含一个或多个 JAR 文件的 ZIP 文件)上传到 S3 存储桶,并在创建插件时指定存储桶的位置。创建插件后,MSK Connect 会复制该时间点的 S3 对象的内容。它不维护指向 S3 对象的链接,因此对该对象的任何后续修改都不会影响插件或其连接器。创建连接器时,需要指定您想要 MSK Connect 用于该连接器的插件。插件与连接器的关系是 one-to-many:你可以从同一个插件创建一个或多个连接器。
注意
自定义插件无法在原地更新。要使用插件代码的新版本,请删除所有引用该插件的连接器,删除该插件,然后重新创建它。
自定义插件的依赖包装
我们建议您为插件添加所有必需的 JAR 文件和依赖项。Package 将您的连接器打包为以下之一:
一个 ZIP 文件,其中包含插件所需的所有必需的 JAR 文件和依赖关系。
一个 uber JAR,其中包含插件及其依赖项的所有类文件。
不捆绑插件依赖关系可能会影响运行时环境中的可用性或兼容性,并导致意外错误。
有关如何开发连接器代码的信息,请参阅 Apache Kafka 文档中的连接器开发指南
使用创建自定义插件 Amazon Web Services 管理控制台
在 https://console.amazonaws.cn/msk/
打开 Amazon MSK 控制台。 在左侧窗格的 MSK Connect 下,选择自定义插件。
选择创建自定义插件。
-
选择浏览 S3。
-
在 S3 存储桶列表中,选择包含插件的 JAR 或 ZIP 文件的存储桶。
-
在对象列表中,选中插件的 JAR 或 ZIP 文件左侧的复选框,然后选择选择。
-
选择创建自定义插件。
要使用 MSK Connect API 创建自定义插件,请参阅CreateCustomPlugin。