This topic describes the types of connectors supported by ApsaraMQ for Confluent. It also describes how to add and remove a connector.
Connector types
Confluent Connectors includes Open Source Connectors, Commercial Connectors, and Premium Connectors. The following table describes the details of these connectors.
Confluent allows you to install different connectors based on the version of the instance.
Professional Edition
Only
Open Source Connectors.Enterprise Edition
Open Source Connectors,Commercial Connectors, andPremium Connectors.
Open Source Connectors
Connector Name | 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] |
Add a connector
Connector plug-ins are available only after you purchase the Connect component. To add the component to an instance, upgrade the instance configuration.
Enterprise Edition allows you to add connectors that are not in the connector category. To do so, prepare your connector package and submit a ticket.
The plug-in is available in the Control Center console only after it is installed in the ApsaraMQ for Confluent console.
Log on to the ApsaraMQ for Confluent console. In the left-side navigation pane, click Instances.
In the top navigation bar, select the region where your ApsaraMQ for Confluent instance resides. Locate the target instance and click its name.
In the left-side navigation pane, click Connectors. Then, click Add Connector.
In the Add Connector panel, search for and select the target connector, click
, and then click OK. ImportantWhen you add a connector, any running job will be stopped and the service will restart. Make sure the job is finished before proceeding, or use the force update option if available.
After the installation, log on to the Control Center console and go to the Cluster overview page. In the left-side navigation pane, click Connect. Then, choose connect from the Cluster name column, before clicking Add connector to view the deployed connector.
Remove a connector
On the Connectors page, select the target connector and click Remove.
In the Note message, click OK.