This topic describes the connector types supported by different versions of ApsaraMQ for Confluent and how to install and uninstall them.
Connector categories
Confluent Connector supports open source connectors, commercial connectors, and premium connectors. The table below describes these connector types.
ApsaraMQ for Confluent supports different connectors depending on the instance version:
Professional
Includes only
OpenSource Connectors.Enterprise
Includes
OpenSource Connectors,Commercial Connectors, andPremium Connectors.
Open source connectors
Connector | Owner | Type |
debezium-connector-mongodb | debezium | [source] |
debezium-connector-mysql | debezium | [source] |
debezium-connector-postgresql | debezium | [source] |
debezium-connector-sqlserver | debezium | [source] |
diffusion-connector | push | [source sink] |
gridgain-kafka-connect | gridgain | [source sink] |
ignite-connector | gridgain | [source sink] |
kafka-connect-ably | ably | [sink] |
kafka-connect-aerospike-sink | aerospike | [sink] |
kafka-connect-as400 | infoviewsystems | [source sink] |
kafka-connect-bigquery | wepay | [sink] |
kafka-connect-cassandra-sink | datastax | [sink] |
kafka-connect-cosmos | microsoftcorporation | [source sink] |
kafka-connect-couchbase | couchbase | [transform source sink] |
kafka-connect-crux | juxt | [source sink] |
kafka-connect-datagen | confluentinc | [source] |
kafka-connect-elasticsearch | confluentinc | [sink] |
kafka-connect-geode | apache | [source sink] |
kafka-connect-hdfs | confluentinc | [sink] |
kafka-connect-hec-sink | humio | [sink] |
kafka-connect-jdbc | confluentinc | [source sink] |
kafka-connect-jdbc_flatten | norsktipping | [source] |
kafka-connect-logs | datadog | [sink] |
kafka-connect-mongodb | mongodb | [source] |
kafka-connect-neo4j | neo4j | [source] |
kafka-connect-odatabusevent | init | [source] |
kafka-connect-odp | init | [source] |
kafka-connect-redis | jcustenborder | [sink] |
kafka-connect-rockset | rockset | [sink] |
kafka-connect-s3 | confluentinc | [sink] |
kafka-connect-splunk | splunk | [sink] |
kafka-connect-spooldir | jcustenborder | [source] |
kafka-connect-tigergraph | experoinc | [source sink] |
kafka-connect-venafi | opencredo | [source] |
kafka-sink-azure-kusto | microsoftcorporation | [sink] |
kinetica-connector | kinetica | [source sink] |
newrelic-kafka-connector | newrelic | [sink] |
oracdc-kafka | a2solutions | [source sink] |
privitar-kafka-connector | privitar | [sink] |
scylla-cdc-source-connector | scylladb | [source] |
singlestore-kafka-connector | singlestore | [sink] |
snowflake-kafka-connector | snowflakeinc | [sink] |
streaming-connect-sink | adobeinc | [sink] |
yb-kafka-connector | yugabyteinc | [sink] |
Commercial connectors
Connector name | Owner | Type |
kafka-connect-activemq | confluentinc | source |
kafka-connect-activemq-sink | confluentinc | sink |
kafka-connect-amps | confluentinc | source |
kafka-connect-appdynamics-metrics | confluentinc | sink |
kafka-connect-aws-cloudwatch-logs | confluentinc | source |
kafka-connect-aws-cloudwatch-metrics | confluentinc | sink |
kafka-connect-aws-dynamodb | confluentinc | sink |
kafka-connect-aws-lambda | confluentinc | sink |
kafka-connect-aws-redshift | confluentinc | sink |
kafka-connect-azure-blob-storage | confluentinc | sink |
kafka-connect-azure-blob-storage-source | confluentinc | source |
kafka-connect-azure-data-lake-gen1-storage | confluentinc | sink |
kafka-connect-azure-data-lake-gen2-storage | confluentinc | sink |
kafka-connect-azure-event-hubs | confluentinc | source |
kafka-connect-azure-functions | confluentinc | sink |
kafka-connect-azure-search | confluentinc | sink |
kafka-connect-azure-service-bus | confluentinc | source |
kafka-connect-azure-sql-dw | confluentinc | sink |
kafka-connect-cassandra | confluentinc | sink |
kafka-connect-data-diode | confluentinc | source, sink |
kafka-connect-databricks-delta-lake | confluentinc | sink |
kafka-connect-datadog-metrics | confluentinc | sink |
kafka-connect-firebase | confluentinc | source, sink |
kafka-connect-ftps | confluentinc | source, sink |
kafka-connect-gcp-bigtable | confluentinc | sink |
kafka-connect-gcp-dataproc-sink | confluentinc | sink |
kafka-connect-gcp-functions | confluentinc | sink |
kafka-connect-gcp-pubsub | confluentinc | source |
kafka-connect-gcp-spanner | confluentinc | sink |
kafka-connect-gcs | confluentinc | sink |
kafka-connect-gcs-source | confluentinc | source |
kafka-connect-github | confluentinc | source |
kafka-connect-hbase | confluentinc | sink |
kafka-connect-hdfs2-source | confluentinc | source |
kafka-connect-hdfs3 | confluentinc | sink |
kafka-connect-hdfs3-source | confluentinc | source |
kafka-connect-http | confluentinc | sink |
kafka-connect-ibmmq | confluentinc | source |
kafka-connect-ibmmq-sink | confluentinc | sink |
kafka-connect-influxdb | confluentinc | source, sink |
kafka-connect-jira | confluentinc | source |
kafka-connect-jms | confluentinc | source |
kafka-connect-jms-sink | confluentinc | sink |
kafka-connect-kinesis | confluentinc | source |
kafka-connect-kudu | confluentinc | source, sink |
kafka-connect-maprdb | confluentinc | sink |
kafka-connect-marketo | confluentinc | source |
kafka-connect-mqtt | confluentinc | source, sink |
kafka-connect-netezza | confluentinc | sink |
kafka-connect-omnisci | confluentinc | sink |
kafka-connect-pagerduty | confluentinc | sink |
kafka-connect-pivotal-gemfire | confluentinc | sink |
kafka-connect-prometheus-metrics | confluentinc | sink |
kafka-connect-rabbitmq | confluentinc | transform, source |
kafka-connect-rabbitmq-sink | confluentinc | sink |
kafka-connect-s3-source | confluentinc | source |
kafka-connect-salesforce | confluentinc | source, sink |
kafka-connect-salesforce-bulk-api | confluentinc | source, sink |
kafka-connect-servicenow | confluentinc | source, sink |
kafka-connect-sftp | confluentinc | source, sink |
kafka-connect-snmp | confluentinc | source |
kafka-connect-solace-sink | confluentinc | sink |
kafka-connect-solace-source | confluentinc | source |
kafka-connect-splunk-source | confluentinc | source |
kafka-connect-sqs | confluentinc | source |
kafka-connect-syslog | confluentinc | source |
kafka-connect-teradata | confluentinc | source, sink |
kafka-connect-tibco-sink | confluentinc | sink |
kafka-connect-tibco-source | confluentinc | source |
kafka-connect-vertica | confluentinc | sink |
kafka-connect-weblogic | confluentinc | source |
kafka-connect-zendesk | confluentinc | source |
Premium connectors
Connector name | Owner | Type |
kafka-connect-oracle-cdc | confluentinc | [source] |
kafka-connect-splunk-s2s | confluentinc | [source] |
Install a connector
The connector feature is available only after you purchase the Connect service. If your instance lacks this service, you can add it by upgrading the instance configuration.
Enterprise Edition supports custom connectors that are not in the connector catalog. To install a custom connector, you must submit a ticket and provide a validated connector package.
You must install a connector in the ApsaraMQ for Confluent console before you can use it in the Control Center console.
Log on to the ApsaraMQ for Confluent console. In the left-side navigation pane, click Instances.
In the top navigation bar, select a region. Click the name of the target instance.
In the navigation pane on the left, click Connectors, and then click Add Connector.
In the Add Connector panel, search for the connector to install, select the checkbox for the desired version, click
and then click OK.ImportantAdding a connector stops all running jobs and restarts the Connect service. Ensure all jobs are complete or perform a force update before you proceed.
For example, search for
mysqland select debezium-connector-mysql (version 2.4.2).After the installation is complete, log on to the Control Center console and go to the Cluster overview page. In the navigation pane on the left, click Connect. In the Cluster name column, click connect, and then click Add Connector.
From the list of connectors, select MySqlConnector (Source type).
Remove connector
On the Connectors page, select the connector you want to remove, and then click Remove Connector.
In the confirmation dialog box, review the message and click Tips.