Kafka Connect plugins are a collection of components used for streaming data between Kafka and other systems. They typically encapsulate connectors, transforms, and converters for specific data processing scenarios. The AutoMQ managed Kafka Connect service comes with several system plugins that have been officially tested and verified. At the same time, to meet diverse data integration needs, AutoMQ also supports users uploading and managing custom plugins.Documentation Index
Fetch the complete documentation index at: https://docs.automq.com/llms.txt
Use this file to discover all available pages before exploring further.
View Plugin List
Users can view all available system plugins and custom plugins in the current environment through the plugin list. Procedure:- Log in to the AutoMQ Console.
- In the left navigation bar, click the Kafka Connect menu.
- You will be directed to the Plugins list page by default.
Create Custom Plugin
When you need to use a plugin that is not officially provided, you can create a custom plugin through the console. Procedure:- First, the user uploads the custom plugin to a publicly downloadable location (e.g., S3 Bucket or internal file server) and obtains the plugin URL (e.g., S3 URL or CDN download address).
- On the plugin list page, click the “Create Custom Plugin” button.
- In the dialog box, fill in the basic metadata for the plugin, including: (a) Name, version, and description; (b) Main Class of the plugin; (c) Other necessary parameters.
Delete Custom Plugin
When you no longer need a specific version of a custom plugin, you can choose to delete it to free up resources and simplify management. Procedure:- On the Plugins list page, find the custom plugin you want to delete.
- Click the Delete button on the right side of the corresponding plugin.
- Complete the operation in the confirmation dialog box.
- System Plugins: Cannot be deleted.
- In-Use Plugins: If a plugin (or any of its versions) is being used by one or more Connect tasks, it cannot be deleted. You must first stop and delete the relevant tasks.