ApsaraMQ for Kafka は、ApsaraMQ for Kafka と他の Alibaba Cloud サービス間でデータを同期するためのフルマネージドコネクタを提供します。これらのコネクタで O&M 操作を実行する必要はありません。このトピックでは、コネクタの種類、コネクタの使用手順と制限について説明します。また、コネクタを使用して異なるリージョンにあるサービス間でデータを同期する方法についても説明します。
ApsaraMQ for Kafka のコネクタ機能はパブリックプレビュー中です。この機能は ApsaraMQ for Kafka インスタンスとは独立しています。コネクタを使用して Message Queue for Apache Kafka と別の Alibaba Cloud サービス間でデータを同期する場合、ApsaraMQ for Kafka 側では課金されません。Alibaba Cloud は、コネクタ機能のサービスレベルアグリーメント (SLA) を提供していません。必要な他のサービスの SLA と料金については、関連サービスのドキュメントをご参照ください。
コネクタの種類
ApsaraMQ for Kafka は 2 種類のコネクタを提供します。
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 のコネクタに関する制限を示します。
項目 | 制限 |
数量 | 1 つの Message Queue for Apache Kafka インスタンスに対して最大 20 個のコネクタを作成できます。同じ Message Queue for Apache Kafka インスタンスから異なるサービスにデータをエクスポートするために、複数のコネクタタスクを作成できます。 |
リージョン | コネクタ機能は一部のリージョンでは使用できません。詳細については、「サポートされているリージョン」をご参照ください。 |
リージョン間でのデータの同期
インターネット経由で異なるリージョンにデプロイされている Alibaba Cloud サービス間でデータを同期するためにコネクタを使用する必要がある場合は、コネクタのインターネットアクセスを有効にする必要があります。詳細については、「コネクタのインターネットアクセスを有効にする」をご参照ください。
MySQL ソースコネクタを使用してリージョン間でデータを同期する必要がある場合は、Cloud Enterprise Network をアクティブ化する必要があります。詳細については、「MySQL Source コネクタの作成」をご参照ください。