全部產品
Search

搜尋本產品

    ApsaraMQ for Kafka：Connector外掛程式管理

    文件中心

    ApsaraMQ for Kafka：Connector外掛程式管理

    更新時間：Nov 20, 2025

    本文向您介紹不同版本雲訊息佇列 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分類中的Connector。您需要提交工單，並準備和提供經過客戶驗證的Connector包。

    • Connector外掛程式需要在雲訊息佇列 Confluent 版控制台安裝完成後，才能在Control Center控制台中正常使用。

    1. 登入雲訊息佇列 Confluent 版控制台，在左側導覽列，單擊实例列表。

    2. 在頂部功能表列，選擇地區。單擊目標執行個體名稱。

    3. 在左側導覽列，單擊Connector外掛程式管理，然後單擊添加Connector外掛程式。

    4. 在添加Connector外掛程式面板中，查詢要安裝的Connector，選中需要安裝的版本的複選框後，再單擊image，最後單擊確定。

      重要

      添加Connector外掛程式會導致當前啟動並執行job停止運行，並且會重啟服務，請確認job是否完成或進行強制更新。

      image

    5. 安裝成功後，登入Control Center控制台，進入到Cluster overview頁面。在首頁的左側導覽列，單擊Connect，然後單擊Cluster name列中的connect，再單擊Add connector，即可看到部署完成的Connector。

      image

    卸載Connector

    1. 在Connector外掛程式管理頁面，勾選需要卸載的外掛程式，單擊卸載Connector外掛程式。

    2. 在提示對話方塊，閱讀提示內容後，單擊確定。