管理插件

Kafka Connect 插件包含在 Kafka 与外部系统之间传输或处理数据所需的 Connector、Transform 和 Converter。AutoMQ Connect 支持以下两类插件：

• Managed 插件： 由 AutoMQ 维护和验证，并提供给 Connect Cluster 使用。
• 自定义插件： 当 Managed 插件不能满足需求时，由用户自行上传和管理。

​

查看插件列表

1. 登录 AutoMQ 控制台。
2. 在导航栏中选择 Kafka Connect。
3. 选择 Plugins 页签。

AutoMQ 控制台中的插件目录是当前环境可用插件版本的权威来源。本附录列出本版本包含的 Managed 插件文档。

​

创建自定义插件

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

​

删除自定义插件

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

​

更新自定义插件

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

​

附录：Managed 插件文档

以下 Managed 插件文档包含前置条件、配置、监控和故障排查信息。当前环境可用的插件版本以 AutoMQ 控制台显示为准。

​

Source Connector

​

Sink Connector