ApsaraMQ for Kafka は、ApsaraMQ for Kafka と他の Alibaba Cloud サービス間でデータを同期するための、フルマネージドで運用不要のシンクコネクタを提供します。このトピックでは、シンクコネクタを使用するための前提条件と、シンクコネクタでサポートされているデータ同期タスクのタイプについて説明します。
前提条件
シンクコネクタは、EventBridge と Function Compute に基づいて実装されています。シンクコネクタを使用する前に、以下のサービスがアクティブになっていることを確認してください。
Function Compute がアクティブ化されている。詳細については、「関数をすばやく作成する」をご参照ください。
課金
EventBridge はパブリックプレビュー中です。パブリックプレビュー中は無料です。
Function Compute の課金については、「課金概要」をご参照ください。
コネクタの種類
シンクコネクタの「シンク」は、データの流出を示します。Message Queue for Apache Kafka が提供するシンクコネクタを使用する場合、ApsaraMQ for Kafka はデータソースとして機能し、他のサービスはデータの宛先として機能します。次の表に、シンクコネクタの種類を示します。
コネクタ | 説明 | 参照 |
Function Compute シンクコネクタ | ApsaraMQ for Kafka から Function Compute にデータを同期します。 | |
MaxCompute シンクコネクタ | ApsaraMQ for Kafka から MaxCompute にデータを同期します。 | |
OSS シンクコネクタ | ApsaraMQ for Kafka から Object Storage Service ( OSS ) にデータを同期します。 | |
Elasticsearch シンクコネクタ | ApsaraMQ for Kafka から Elasticsearch にデータを同期します。 | |
Tablestore シンクコネクタ | ApsaraMQ for Kafka から Tablestore にデータを同期します。 | |
Log Service シンクコネクタ | ApsaraMQ for Kafka から Log Service にデータを同期します。 | |
AnalyticDB シンクコネクタ | ApsaraMQ for Kafka から AnalyticDB for MySQL または AnalyticDB for PostgreSQL にデータを同期します。 |