この Topic では、ApsaraMQ for Confluent のさまざまなエディションでサポートされているコネクタの種類と、コネクタコンポーネントをインストールおよびアンインストールする方法について説明します。
コネクタの種類
Confluent Connectors には、OpenSource Connectors、Commercial Connectors、および Premium Connectors が含まれます。次の表に、これらのコネクタの詳細を示します。
ApsaraMQ for Confluent インスタンスのエディションによって、サポートされるコネクタの種類が異なります。
Professional Edition
OpenSource Connectorsのみをインストールできます。Enterprise Edition
OpenSource Connectors、Commercial Connectors、およびPremium Connectorsをインストールできます。
OpenSource Connectors
コネクタ名 | 所有者 | タイプ |
debezium-connector-mongodb | debezium | [ソース] |
debezium-connector-mysql | debezium | [ソース] |
debezium-connector-postgresql | debezium | [ソース] |
debezium-connector-sqlserver | debezium | [ソース] |
diffusion-connector | push | [ソース シンク] |
gridgain-kafka-connect | gridgain | [ソース シンク] |
ignite-connector | gridgain | [ソース シンク] |
kafka-connect-ably | ably | [シンク] |
kafka-connect-aerospike-sink | aerospike | [シンク] |
kafka-connect-as400 | infoviewsystems | [ソース シンク] |
kafka-connect-bigquery | wepay | [シンク] |
kafka-connect-cassandra-sink | datastax | [シンク] |
kafka-connect-cosmos | microsoftcorporation | [ソース シンク] |
kafka-connect-couchbase | couchbase | [変換 ソース シンク] |
kafka-connect-crux | juxt | [ソース シンク] |
kafka-connect-datagen | confluentinc | [ソース] |
kafka-connect-elasticsearch | confluentinc | [シンク] |
kafka-connect-geode | apache | [ソース シンク] |
kafka-connect-hdfs | confluentinc | [シンク] |
kafka-connect-hec-sink | humio | [シンク] |
kafka-connect-jdbc | confluentinc | [ソース シンク] |
kafka-connect-jdbc_flatten | norsktipping | [ソース |
kafka-connect-logs | datadog | [シンク] |
kafka-connect-mongodb | mongodb | [ソース |
kafka-connect-neo4j | neo4j | [ソース |
kafka-connect-odatabusevent | init | [ソース] |
kafka-connect-odp | init | [ソース] |
kafka-connect-redis | jcustenborder | [シンク] |
kafka-connect-rockset | rockset | [シンク] |
kafka-connect-s3 | confluentinc | [シンク] |
kafka-connect-splunk | splunk | [シンク] |
kafka-connect-spooldir | jcustenborder | [ソース] |
kafka-connect-tigergraph | experoinc | [ソース シンク] |
kafka-connect-venafi | opencredo | [ソース] |
kafka-sink-azure-kusto | microsoftcorporation | [シンク] |
kinetica-connector | kinetica | [ソース シンク] |
newrelic-kafka-connector | newrelic | [シンク] |
oracdc-kafka | a2solutions | [ソース シンク] |
privitar-kafka-connector | privitar | [シンク] |
scylla-cdc-source-connector | scylladb | [ソース] |
singlestore-kafka-connector | singlestore | [シンク] |
snowflake-kafka-connector | snowflakeinc | [シンク] |
streaming-connect-sink | adobeinc | [シンク] |
yb-kafka-connector | yugabyteinc | [シンク] |
Commercial Connectors
コネクタ名 | 所有者 | タイプ |
kafka-connect-activemq | confluentinc | [ソース] |
kafka-connect-activemq-sink | confluentinc | [シンク] |
kafka-connect-amps | confluentinc | [ソース] |
kafka-connect-appdynamics-metrics | confluentinc | [シンク] |
kafka-connect-aws-cloudwatch-logs | confluentinc | [ソース] |
kafka-connect-aws-cloudwatch-metrics | confluentinc | [シンク] |
kafka-connect-aws-dynamodb | confluentinc | [シンク] |
kafka-connect-aws-lambda | confluentinc | [シンク] |
kafka-connect-aws-redshift | confluentinc | [シンク] |
kafka-connect-azure-blob-storage | confluentinc | [シンク] |
kafka-connect-azure-blob-storage-source | confluentinc | [ソース] |
kafka-connect-azure-data-lake-gen1-storage | confluentinc | [シンク] |
kafka-connect-azure-data-lake-gen2-storage | confluentinc | [シンク] |
kafka-connect-azure-event-hubs | confluentinc | [ソース] |
kafka-connect-azure-functions | confluentinc | [シンク] |
kafka-connect-azure-search | confluentinc | [シンク] |
kafka-connect-azure-service-bus | confluentinc | [ソース] |
kafka-connect-azure-sql-dw | confluentinc | [シンク] |
kafka-connect-cassandra | confluentinc | [シンク] |
kafka-connect-data-diode | confluentinc | [ソース シンク] |
kafka-connect-databricks-delta-lake | confluentinc | [シンク] |
kafka-connect-datadog-metrics | confluentinc | [シンク] |
kafka-connect-firebase | confluentinc | [ソース シンク] |
kafka-connect-ftps | confluentinc | [ソース シンク] |
kafka-connect-gcp-bigtable | confluentinc | [シンク] |
kafka-connect-gcp-dataproc-sink | confluentinc | [シンク] |
kafka-connect-gcp-functions | confluentinc | [シンク] |
kafka-connect-gcp-pubsub | confluentinc | [ソース] |
kafka-connect-gcp-spanner | confluentinc | [シンク] |
kafka-connect-gcs | confluentinc | [シンク] |
kafka-connect-gcs-source | confluentinc | [ソース] |
kafka-connect-github | confluentinc | [ソース] |
kafka-connect-hbase | confluentinc | [シンク] |
kafka-connect-hdfs2-source | confluentinc | [ソース] |
kafka-connect-hdfs3 | confluentinc | [シンク] |
kafka-connect-hdfs3-source | confluentinc | [ソース] |
kafka-connect-http | confluentinc | [シンク] |
kafka-connect-ibmmq | confluentinc | [ソース] |
kafka-connect-ibmmq-sink | confluentinc | [シンク] |
kafka-connect-influxdb | confluentinc | [ソース シンク] |
kafka-connect-jira | confluentinc | [ソース] |
kafka-connect-jms | confluentinc | [ソース] |
kafka-connect-jms-sink | confluentinc | [シンク] |
kafka-connect-kinesis | confluentinc | [ソース] |
kafka-connect-kudu | confluentinc | [ソース シンク] |
kafka-connect-maprdb | confluentinc | [シンク] |
kafka-connect-marketo | confluentinc | [ソース] |
kafka-connect-mqtt | confluentinc | [ソース シンク] |
kafka-connect-netezza | confluentinc | [シンク] |
kafka-connect-omnisci | confluentinc | [シンク] |
kafka-connect-pagerduty | confluentinc | [シンク] |
kafka-connect-pivotal-gemfire | confluentinc | [シンク] |
kafka-connect-prometheus-metrics | confluentinc | [シンク] |
kafka-connect-rabbitmq | confluentinc | [変換ソース] |
kafka-connect-rabbitmq-sink | confluentinc | [シンク] |
kafka-connect-s3-source | confluentinc | [ソース] |
kafka-connect-salesforce | confluentinc | [ソース シンク] |
kafka-connect-salesforce-bulk-api | confluentinc | [ソース シンク] |
kafka-connect-servicenow | confluentinc | [ソース シンク] |
kafka-connect-sftp | confluentinc | [ソース シンク] |
kafka-connect-snmp | confluentinc | [ソース] |
kafka-connect-solace-sink | confluentinc | [シンク] |
kafka-connect-solace-source | confluentinc | [ソース] |
kafka-connect-splunk-source | confluentinc | [ソース] |
kafka-connect-sqs | confluentinc | [ソース] |
kafka-connect-syslog | confluentinc | [ソース] |
kafka-connect-teradata | confluentinc | [ソース シンク] |
kafka-connect-tibco-sink | confluentinc | [シンク] |
kafka-connect-tibco-source | confluentinc | [ソース] |
kafka-connect-vertica | confluentinc | [シンク] |
kafka-connect-weblogic | confluentinc | [ソース] |
kafka-connect-zendesk | confluentinc | [ソース] |
Premium Connectors
コネクタ名 | 所有者 | タイプ |
kafka-connect-oracle-cdc | confluentinc | [ソース] |
kafka-connect-splunk-s2s | confluentinc | [ソース] |
コネクタのインストール
Kafka Connect リソースを購入した後にのみ、コネクタプラグインを使用できます。インスタンスに Kafka Connect コンポーネントがない場合は、インスタンスをアップグレードして追加できます。詳細については、「インスタンスのアップグレード」をご参照ください。
Enterprise Edition インスタンスは、コネクタカテゴリにリストされていないカスタムコネクタをサポートします。カスタムコネクタを追加するには、チケットを送信して、検証済みのコネクタパッケージを提供してください。
ApsaraMQ for Confluent コンソールにコネクタプラグインをインストールした後にのみ、Control Center コンソールでコネクタプラグインを使用できます。
ApsaraMQ for Confluent コンソールにログインします。左側のナビゲーションウィンドウで、インスタンスリスト をクリックします。
上部のメニューバーでリージョンを選択し、対象のインスタンスの名前をクリックします。
左側のナビゲーションウィンドウで [コネクタプラグイン管理] をクリックし、次に [コネクタプラグインの追加] をクリックします。
[コネクタプラグインの追加] パネルで、インストールするコネクタを見つけます。必要なバージョンのチェックボックスを選択し、
をクリックしてから、[OK] をクリックします。重要コネクタプラグインを追加すると、実行中のジョブがすべて停止し、サービスが再起動します。ジョブが完了したことを確認するか、強制更新を実行してください。
インストールが完了したら、Control Center コンソールにログインし、[クラスターの概要] ページに移動します。左側のナビゲーションウィンドウで [Connect] をクリックします。[クラスター名] 列の [connect] をクリックし、次に [コネクタの追加] をクリックします。これで、デプロイされたコネクタを表示できます。
コネクタのアンインストール
[コネクタプラグイン管理] ページで、アンインストールするプラグインの横にあるチェックボックスを選択し、次に [コネクタプラグインのアンインストール] をクリックします。
[通知] ダイアログボックスで、メッセージを読み、[OK] をクリックします。