跳转到主要内容
Kafka Connect 插件是用于在 Kafka 与其他系统间流式传输数据的组件集合，通常封装了特定数据处理场景下的连接器（Connector）、数据转换（Transform）和转换器（Converter）等工具包。 AutoMQ 托管 Kafka Connect 服务内置了若干经过官方测试和验证的系统插件。同时，为了满足多样化的数据集成需求，AutoMQ 也支持用户上传和管理自定义插件。

​
查看插件列表

用户可通过插件列表查看当前环境中所有可用的系统插件和自定义插件。 操作流程：
  1. 登录 AutoMQ 控制台。
  2. 在左侧导航栏中，点击 Kafka Connect 菜单。
  3. 默认进入 插件 列表页面。
在此页面，您可以看到所有已集成的系统插件，这些插件可直接用于创建 Connect 任务。如果系统插件无法满足您的特定需求，您可以从第三方社区下载插件，或自行开发并上传。

​
创建自定义插件

当需要使用官方未提供的插件时，您可以通过控制台创建自定义插件。 操作流程：
  1. 首先，用户将自定义插件上传到一个可以公开下载的地方（例如 S3 Bucket 或企业内部的文件服务器），获取上传后的插件 URL（如 S3 URL 或下载的 CDN 地址）。
  2. 在插件列表页面，点击“创建自定义插件”按钮。
  3. 在弹出的对话框中填写插件的基本元信息，包括： (a) 名称、版本及描述； (b) 插件的主 Class； (c) 其他必要参数。
系统将对插件进行预检验，最后点击确认即可完成插件的创建。

​
删除自定义插件

当您不再需要某个自定义插件的特定版本时，可以选择将其删除以释放资源和简化管理。 操作流程：
  1. 在 插件 列表页面，找到需要删除的自定义插件。
  2. 点击对应插件右侧的 删除 按钮。
  3. 在确认对话框中完成操作。
请注意以下约束：
  • 系统插件：不允许被删除。
  • 使用中的插件：如果一个插件（或其任何版本）正在被一个或多个 Connect 任务使用，则无法删除，必须先停止并删除相关任务。

​
更新插件

当社区发布了新版本的插件，或者您自己的自定义插件有了新版本时，可以通过上传新版本来完成更新。 操作流程： 更新插件的操作流程与上传自定义插件完全相同。AutoMQ 托管 Kafka Connect 服务支持同一插件的多个版本并存，不同版本之间相互独立，互不影响。您可以在创建 Connect 任务时，根据需要选择使用特定版本的插件。