Skip to main content

custom_connector_plugins

Creates, updates, deletes, gets or lists a custom_connector_plugins resource.

Overview

Namecustom_connector_plugins
TypeResource
Idconfluent.connect.custom_connector_plugins

Fields

The following fields are returned by SELECT queries:

Custom Connector Plugin.

NameDatatypeDescription
idstringID is the "natural identifier" for an object within its scope/namespace; it is normally unique across time but not space. That is, you can assume that the ID will not be reclaimed and reused after an object is deleted ("time"); however, it may collide with IDs for other object kinds or objects of the same kind within a different scope/namespace ("space"). (example: dlz-f3a90de)
display_namestringDisplay name of Custom Connector Plugin.
api_versionstringAPIVersion defines the schema version of this representation of a resource. (connect/v1)
cloudstringCloud provider where the Custom Connector Plugin archive is uploaded. (example: AWS, default: AWS)
connector_classstringJava class or alias for connector. You can get connector class from connector documentation provided by developer. (pattern: ^(([a-zA-Z][a-zA-Z_$0-9](.[a-zA-Z][a-zA-Z_$0-9])).)?([a-zA-Z][a-zA-Z_$0-9])$, example: io.confluent.kafka.connect.datagen.DatagenConnector)
connector_typestringCustom Connector type. (example: SOURCE)
content_formatstringArchive format of Custom Connector Plugin. (example: ZIP)
descriptionstringDescription of Custom Connector Plugin.
documentation_linkstringDocument link of Custom Connector Plugin. (pattern: ^$|^(http://|https://).+, example: https://github.com/confluentinc/kafka-connect-datagen)
kindstringKind defines the object this REST resource represents. (CustomConnectorPlugin)
metadataobjectObjectMeta is metadata that all persisted resources must have, which includes all objects users must create.
runtime_languagestringRuntime language of Custom Connector Plugin. (example: JAVA, default: JAVA)
sensitive_config_propertiesarrayA sensitive property is a connector configuration property that must be hidden after a user enters property value when setting up connector.
upload_sourceobjectUpload source of Custom Connector Plugin. Only required in create request, will be ignored in read, update or list.

Methods

The following methods are available for this resource:

NameAccessible byRequired ParamsOptional ParamsDescription
get_connect_v1_custom_connector_pluginselectidMake a request to read a custom connector plugin.
list_connect_v1_custom_connector_pluginsselectcloud, page_size, page_tokenRetrieve a sorted, filtered, paginated list of all custom connector plugins.

If no cloud filter is specified, returns custom connector plugins from all clouds.
create_connect_v1_custom_connector_plugininsertdisplay_name, connector_class, connector_type, upload_sourceMake a request to create a custom connector plugin.
update_connect_v1_custom_connector_pluginupdateidMake a request to update a custom connector plugin.

delete_connect_v1_custom_connector_plugindeleteidMake a request to delete a custom connector plugin.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

NameDatatypeDescription
idstringThe unique identifier for the custom connector plugin.
cloudstringFilter the results by exact match for cloud. (example: AWS)
page_sizeintegerA pagination size for collection requests.
page_tokenstringAn opaque pagination token for collection requests.

SELECT examples

Make a request to read a custom connector plugin.

SELECT
id,
display_name,
api_version,
cloud,
connector_class,
connector_type,
content_format,
description,
documentation_link,
kind,
metadata,
runtime_language,
sensitive_config_properties,
upload_source
FROM confluent.connect.custom_connector_plugins
WHERE id = '{{ id }}' -- required
;

INSERT examples

Make a request to create a custom connector plugin.

INSERT INTO confluent.connect.custom_connector_plugins (
display_name,
description,
documentation_link,
connector_class,
connector_type,
cloud,
sensitive_config_properties,
upload_source,
runtime_language
)
SELECT
'{{ display_name }}' /* required */,
'{{ description }}',
'{{ documentation_link }}',
'{{ connector_class }}' /* required */,
'{{ connector_type }}' /* required */,
'{{ cloud }}',
'{{ sensitive_config_properties }}',
'{{ upload_source }}' /* required */,
'{{ runtime_language }}'
RETURNING
id,
display_name,
api_version,
cloud,
connector_class,
connector_type,
content_format,
description,
documentation_link,
kind,
metadata,
runtime_language,
sensitive_config_properties,
upload_source
;

UPDATE examples

Make a request to update a custom connector plugin.

UPDATE confluent.connect.custom_connector_plugins
SET
display_name = '{{ display_name }}',
description = '{{ description }}',
documentation_link = '{{ documentation_link }}',
connector_class = '{{ connector_class }}',
connector_type = '{{ connector_type }}',
cloud = '{{ cloud }}',
sensitive_config_properties = '{{ sensitive_config_properties }}',
upload_source = '{{ upload_source }}',
runtime_language = '{{ runtime_language }}'
WHERE
id = '{{ id }}' --required
RETURNING
id,
display_name,
api_version,
cloud,
connector_class,
connector_type,
content_format,
description,
documentation_link,
kind,
metadata,
runtime_language,
sensitive_config_properties,
upload_source;

DELETE examples

Make a request to delete a custom connector plugin.

DELETE FROM confluent.connect.custom_connector_plugins
WHERE id = '{{ id }}' --required
;