本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

# 创建自定义插件
<a name="msk-connect-plugins"></a>

插件是一种 AWS 资源，其中包含定义连接器逻辑的代码。您可以将 JAR 文件（或包含一个或多个 JAR 文件的 ZIP 文件）上传到 S3 存储桶，并在创建插件时指定存储桶的位置。创建插件后，MSK Connect 会复制该时间点的 S3 对象的内容。它不维护指向 S3 对象的链接，因此对该对象的任何后续修改都不会影响插件或其连接器。创建连接器时，需要指定您想要 MSK Connect 用于该连接器的插件。插件与连接器的关系是 one-to-many：你可以从同一个插件创建一个或多个连接器。

**注意**  
自定义插件无法在原地更新。要使用插件代码的新版本，请删除所有引用该插件的连接器，删除该插件，然后重新创建它。

**自定义插件的依赖包装**  
我们建议您为插件添加所有必需的 JAR 文件和依赖项。Package 将您的连接器打包为以下之一：  
一个 ZIP 文件，其中包含插件所需的所有必需的 JAR 文件和依赖关系。
一个 uber JAR，其中包含插件及其依赖项的所有类文件。
不捆绑插件依赖关系可能会影响运行时环境中的可用性或兼容性，并导致意外错误。

有关如何开发连接器代码的信息，请参阅 Apache Kafka 文档中的[连接器开发指南](https://kafka.apache.org/documentation/#connect_development)。

**使用创建自定义插件 AWS 管理控制台**

1. 在 [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/) 打开 Amazon MSK 控制台。

1. 在左侧窗格的 **MSK Connect** 下，选择**自定义插件**。

1. 选择**创建自定义插件**。

1. 选择**浏览 S3**。

1. 在 S3 存储桶列表中，选择包含插件的 JAR 或 ZIP 文件的存储桶。

1. 在对象列表中，选中插件的 JAR 或 ZIP 文件左侧的复选框，然后选择**选择**。

1. 选择**创建自定义插件**。

要使用 MSK Connect API 创建自定义插件，请参阅[CreateCustomPlugin](https://docs.aws.amazon.com/MSKC/latest/mskc/API_CreateCustomPlugin.html)。