插件 - Amazon Managed Streaming for Apache Kafka

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

插件

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

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

使用创建自定义插件 AWS Management Console

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

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

  3. 选择创建自定义插件。

  4. 选择浏览 S3。

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

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

  7. 选择创建自定义插件。

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