Skip to main content
Kafka Connect 插件包含在 Kafka 与外部系统之间传输或处理数据所需的 Connector、Transform 和 Converter。AutoMQ Connect 支持以下两类插件:
  • Managed 插件: 由 AutoMQ 维护和验证,并提供给 Connect Cluster 使用。
  • 自定义插件: 当 Managed 插件不能满足需求时,由用户自行上传和管理。

查看插件列表

  1. 登录 AutoMQ 控制台。
  2. 在导航栏中选择 Kafka Connect
  3. 选择 Plugins 页签。
截至 2026 年 8 月,AutoMQ 提供以下 Managed 插件:
提示如果当前的 Managed 插件列表中未包含您所需的插件,您可以通过提交工单联系我们进行更新,或者临时创建自定义插件来满足使用需求。

创建自定义插件

  1. 将插件包上传到 AutoMQ 环境可下载的位置,并获取下载 URL。
  2. Plugins 页签中选择 Create Custom Plugin
  3. 输入插件名称、版本、描述、Main Class 和其他必填元数据。
  4. 确认配置。AutoMQ 会先验证插件包,再创建该插件版本。

删除自定义插件

Plugins 页签中找到目标自定义插件版本并选择 Delete。Managed 插件不能删除。Connect Cluster 正在引用的自定义插件版本也不能删除;删除前需要先解除引用。

更新自定义插件

按照创建自定义插件的步骤创建新版本。一个自定义插件可以同时存在多个版本;在更新 Connect Cluster 配置前,现有 Connect Cluster 继续使用其当前版本。