创建自定义插件 - Amazon Managed Streaming for Apache Kafka

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

创建自定义插件

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

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

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

  3. 打开 Amazon MSK 控制台,网址为https://console.aws.amazon.com/msk/

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

  5. 选择创建自定义插件

  6. 选择浏览 S3

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

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

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

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

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 主题