本文向您介绍不同版本云消息队列 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
登录云消息队列 Confluent 版控制台，在左侧导航栏，单击实例列表。
-
在顶部菜单栏，选择地域。单击目标实例名称。
-
在左侧导航栏，单击Connector 插件管理，然后单击添加 Connector 插件。
-
在添加 Connector 插件面板中，查询要安装的Connector，选中需要安装的版本的复选框后，再单击
，最后单击确定。重要添加Connector插件会导致当前运行的job停止运行，并且会重启服务，请确认job是否完成或进行强制更新。
例如，搜索
mysql并选中 debezium-connector-mysql（版本 2.4.2）。 -
安装成功后，登录Control Center控制台，进入到Cluster overview页面。在主页的左侧导航栏，单击Connect，然后单击Cluster name列中的connect，再单击Add connector，即可看到部署完成的Connector。
在连接器列表中，选择 MySqlConnector（Source 类型）。
卸载Connector
-
在Connector 插件管理页面，勾选需要卸载的插件，单击卸载 Connector 插件。
-
在提示对话框，阅读提示内容后，单击确定。