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

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

创建自定义插件

插件包含定义连接器逻辑的代码。在此步骤中,您需创建一个包含 Lenses Amazon S3 接收器连接器代码的自定义插件。在后面的步骤中,当您创建 MSK 连接器时,您可以指定其代码位于此自定义插件中。您可以使用同一插件来创建多个具有不同配置的 MSK 连接器。

创建自定义插件
  1. 下载 S3 连接器

  2. 将 ZIP 文件上传到您有权访问的 S3 存储桶。有关如何将文件上传到 Amazon S3 的信息,请参阅《Amazon S3 用户指南》中的上传对象

  3. https://console.amazonaws.cn/msk/ 打开 Amazon MSK 控制台。

  4. 在左侧窗格中展开 MSK Connect,然后选择自定义插件

  5. 选择创建自定义插件

  6. 选择浏览 S3

  7. 在存储桶列表中,找到您上传 ZIP 文件的存储桶,然后选择该存储桶。

  8. 在存储桶的对象列表中,选择 ZIP 文件左侧的单选按钮,然后选择标有选择的按钮。

  9. 输入 mkc-tutorial-plugin 作为自定义插件名称,然后选择创建自定义插件

可能需要 Amazon 几分钟才能完成自定义插件的创建。创建过程完成后,您会在浏览器窗口顶部的横幅中看到以下消息。

Custom plugin mkc-tutorial-plugin was successfully created The custom plugin was created. You can now create a connector using this custom plugin.

下一步

创建客户端计算机和 Apache Kafka 主题