サポートされているセルフマネージド型コネクター¶
Confluent は、最も一般的に使用されているデータシステムからデータをインポートおよびエクスポートする、以下のセルフマネージド型コネクターをサポートしています。
Confluent Confluent Platform コネクターはいずれも、Confluent Hub からダウンロードできます。コネクターのインストール後に、以下のいずれかを行って開始できます。
- コネクター構成を作成し、スタンドアロン Kafka Connect プロセスを開始する。
- Kafka Connect クラスターに REST リクエストを行う。
重要
Confluent Platform バージョン 6.0 以降
Confluent Platform 6.0 より前のリリースでは、以下のコネクターが Confluent Platform にネイティブでバンドルされていました。これらのコネクターは、Confluent Hub からダウンロードしてご利用いただけます。
- Active MQ Source Connector
- Amazon S3 Sink Connector
- Elasticsearch Sink Connector
- HDFS Sink Connector
- IBM MQ Source Connector
- JDBC Connector
- JMS Source Connector
以下のコネクターは、引き続き Confluent Platform にバンドルされています。
Confluent Platform バージョン 6.0(以降)にアップグレードする場合は、使用しているすべてのコネクターの最新バージョンの Confluent Hub をインストールする必要があります。ただし、Replicator と FileStream(FileSource および FileSink)コネクターは例外で、引き続き Confluent Platform にパッケージ化されています。バンドルされていないコネクターとバンドルされている旧コネクターを区別するために、バンドルされている旧コネクターは 10.x.x
を使用してバージョン管理されています。latest
を含んだ以下のコマンドを使用して、アップデートされたコネクターを Confluent Hub からインストールすることができます。
confluent-hub install confluentinc/kafka-connect-s3:latest
confluent-hub install confluentinc/kafka-connect-hdfs:latest
confluent-hub install confluentinc/kafka-connect-elasticsearch:latest
confluent-hub install confluentinc/kafka-connect-jdbc:latest
confluent-hub install confluentinc/kafka-connect-jms:latest
confluent-hub install confluentinc/kafka-connect-activemq:latest
confluent-hub install confluentinc/kafka-connect-ibmmq:latest
以下のコネクターは、Confluent Platform でネイティブにパッケージ化され、使用可能です。
- Confluent Replicator
- FileStream Connectors (Development and Testing)
以下のサポート対象コネクターは、Confluent Hub 経由で別途インストールする必要があります。
- ActiveMQ Sink Connector
- ActiveMQ Source Connector
- Amazon CloudWatch Logs Source Connector
- Amazon CloudWatch Metrics Sink Connector
- Amazon Kinesis Source Connector
- Amazon S3 Sink Connector
- Amazon S3 Source Connector
- Amazon SQS Source Connector
- Apache HBase Sink Connector
- Appdynamics Metrics Sink Connector
- AWS DynamoDB Sink Connector
- AWS Lambda Sink Connector
- AWS Redshift Sink Connector
- Azure Blob Storage Sink Connector
- Azure Blob Storage Source Connector
- Azure Cognitive Search Sink Connector
- Azure Data Lake Storage Gen1 Sink Connector
- Azure Data Lake Storage Gen2 Sink Connector
- Azure Event Hubs Source Connector
- Azure Functions Sink Connector
- Azure Service Bus Source Connector
- Azure Synapse Analytics Sink Connector
- Cassandra Sink Connector
- Data Diode Connector (Source and Sink)
- Datadog Metrics Sink Connector
- Datagen Source Connector (Development Testing)
- Elasticsearch Sink Connector
- GitHub Source Connector
- Google BigQuery Sink Connector
- Google Cloud BigTable Sink Connector
- Google Cloud Dataproc Sink Connector
- Google Cloud Functions Sink Connector
- Google Cloud Pub/Sub Source Connector
- Google Cloud Spanner Sink Connector
- Google Cloud Storage Sink Connector
- Google Cloud Storage Source Connector
- Google Firebase Connector
- HEAVY-AI (formerly OmniSci) Sink Connector
- HDFS 2 Sink Connector
- HDFS 2 Source Connector
- HDFS 3 Sink Connector
- HDFS 3 Source Connector
- HTTP Sink Connector
- IBM MQ Source Connector
- IBM MQ Sink Connector
- InfluxDB Connector (Source and Sink)
- JDBC Connector (Source and Sink)
- JMS Sink Connector
- JMS Source Connector
- Kudu Connector (Source および Sink)
- MapR DB Sink Connector
- Microsoft SQL Server Source Connector (非推奨)
- MongoDB Source Connector (Debezium)
- MQTT Connector (Source および Sink)
- MySQL Source Connector (Debezium)
- Netezza Sink Connector
- Oracle CDC Source Connector
- Pagerduty Sink Connector
- PostgresSQL Source Connector (Debezium)
- RabbitMQ Sink Connector
- RabbitMQ Source Connector
- Redis Sink Connector
- Salesforce Bulk API Source Connector
- Salesforce Change Data Capture Source Connector
- Salesforce Connector (Source および Sink)
- ServiceNow Connector (Source および Sink)
- SFTP Connector (Source および Sink)
- SNMP Trap Source Connector
- Solace (Source および Sink)
- Splunk Sink Connector
- Splunk Source Connector
- Splunk S2S Source Connector
- Spool Dir Connector
- SQL Server Source Connector (Debezium)
- Syslog Source Connector
- Teradata Connector (Source および Sink)
- TIBCO Sink Connector
- TIBCO Source Connector
- Vertica Sink Connector
- VMware Tanzu Gemfire Sink Connector
- Zendesk Source Connector