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

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

创建自定义插件

插件是一种 Amazon 资源,其中包含定义连接器逻辑的代码。您可以将 JAR 文件(或包含一个或多个 JAR 文件的 ZIP 文件)上传到 S3 存储桶,并在创建插件时指定存储桶的位置。创建连接器时,需要指定您想要 MSK Connect 用于该连接器的插件。插件与连接器的关系是 one-to-many:您可以从同一个插件创建一个或多个连接器。

有关如何开发连接器代码的信息,请参阅 Apache Kafka 文档中的连接器开发指南

使用创建自定义插件 Amazon Web Services Management Console
  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