本文向您介绍不同版本云消息队列 Confluent 版所支持的Connector种类，以及如何添加和卸载Connector组件。
Connector分类
Confluent Connector支持OpenSource Connectors、Commercial Connectors和Premium Connectors，各种类型的Connectors详情如下表所示。
云消息队列 Confluent 版根据实例版本的不同，支持安装不同的Connector：
专业版
仅支持安装
OpenSource Connectors。企业版
支持安装
OpenSource Connectors、Commercial Connectors和Premium Connectors。
OpenSource 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] |
安装Connector
只有购买了Connect组件资源后，才能正常使用Connector插件功能。若实例中没有Connect组件，可以通过实例升配进行添加。
Connector插件需要在云消息队列 Confluent 版控制台安装完成后，才能在Control Center控制台中正常使用。
登录云消息队列 Confluent 版控制台，在左侧导航栏，单击实例列表。
在顶部菜单栏，选择地域。单击目标实例名称。
在左侧导航栏，单击Connector插件管理，然后单击添加Connector插件。
在添加Connector插件面板中，查询要安装的Connector，选中需要安装的版本的复选框后，再单击
，最后单击确定。重要添加Connector插件会导致当前运行的job停止运行，并且会重启服务，请确认job是否完成或进行强制更新。
安装成功后，登录Control Center控制台，进入到Cluster overview页面。在主页的左侧导航栏，单击Connect，然后单击Cluster name列中的connect，再单击Add connector，即可看到部署完成的Connector。
卸载Connector
在Connector插件管理页面，勾选需要卸载的插件，单击卸载Connector插件。
在提示对话框，阅读提示内容后，单击确定。