ApsaraMQ for Kafka は、ApsaraMQ for Kafka と他の Alibaba Cloud サービス間でデータを同期できる、フルマネージドの運用不要なコネクタを提供します。このトピックでは、コネクタの種類、コネクタを使用する手順と制限事項について説明します。また、コネクタを使用して異なるリージョンにあるサービス間でデータを同期する方法についても説明します。
ApsaraMQ for Kafka のコネクタ機能は、ApsaraMQ for Kafka インスタンスとは独立しています。ApsaraMQ for Kafka では、コネクタ機能に対して課金されません。Alibaba Cloud は、コネクタ機能のサービスレベルアグリーメント (SLA) を提供していません。コネクタ機能の使用に必要な他のサービスの SLA と料金については、関連サービスのドキュメントをご参照ください。
コネクタの種類
ApsaraMQ for Kafka は、以下の種類のコネクタをサポートしています。
Sink コネクタ: Sink コネクタは、ApsaraMQ for Kafka から他の Alibaba Cloud サービスにデータを同期するために使用されます。
コネクタ
説明
参照
FC sink コネクタ
ApsaraMQ for Kafka から Function Compute にデータを同期します。
MaxCompute sink コネクタ
ApsaraMQ for Kafka から MaxCompute にデータを同期します。
OSS sink コネクタ
ApsaraMQ for Kafka から Object Storage Service (OSS) にデータを同期します。
Elasticsearch sink コネクタ
ApsaraMQ for Kafka から Elasticsearch にデータを同期します。
Tablestore sink コネクタ
ApsaraMQ for Kafka から Tablestore にデータを同期します。
AnalyticDB sink コネクタ
ApsaraMQ for Kafka から AnalyticDB for MySQL または AnalyticDB for PostgreSQL にデータを同期します。
Source コネクタ: Source コネクタは、他の Alibaba Cloud サービスから ApsaraMQ for Kafka にデータを同期するために使用されます。
コネクタ
説明
参照
MySQL source コネクタ
ApsaraDB RDS for MySQL から ApsaraMQ for Kafka にデータを同期します。
コネクタの使用
コネクタを使用するには、次の手順を実行します。
制限事項
ApsaraMQ for Kafka のコネクタ機能には、以下の制限事項が適用されます。
項目 | 制限 |
コネクタの数 | ApsaraMQ for Kafka インスタンスにつき最大 20 個のコネクタを作成できます。同じ ApsaraMQ for Kafka インスタンスから異なるサービスにデータをエクスポートするために、複数のコネクタタスクを作成できます。 |
リージョン | コネクタ機能は、特定のリージョンでは使用できません。詳細については、「サポートされているリージョン」をご参照ください。 |
リージョン間のデータ同期
異なるリージョンにデプロイされている Alibaba Cloud サービス間でコネクタを使用してデータを同期する場合は、コネクタのインターネットアクセスを有効にしてから、インターネット経由でデータを同期する必要があります。詳細については、「コネクタのインターネットアクセスを有効にする」をご参照ください。
MySQL source コネクタを使用してリージョン間でデータを同期する場合は、Cloud Enterprise Network (CEN) をアクティブ化する必要があります。詳細については、「MySQL source コネクタの作成」をご参照ください。