创建自定义插件 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

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

创建自定义插件

插件是一种 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 管理控制台
  1. https://console.amazonaws.cn/msk/ 打开 Amazon MSK 控制台。

  2. 在左侧窗格的 MSK Connect 下,选择自定义插件

  3. 选择创建自定义插件

  4. 选择浏览 S3

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

  6. 在对象列表中,选中插件的 JAR 或 ZIP 文件左侧的复选框,然后选择选择

  7. 选择创建自定义插件

要使用 MSK Connect API 创建自定义插件,请参阅CreateCustomPlugin