すべてのプロダクト
Search
ドキュメントセンター

Data Transmission Service:コンシューマーグループの作成

最終更新日:Mar 18, 2025

変更追跡機能は、コンシューマーグループの作成をサポートしています。複数のコンシューマーグループを確立することで、同じデータソースからのデータ変更を効率的に追跡し、変更追跡に関連するコストを削減できます。

前提条件

追跡インスタンスが作成済みであり、現在 通常 ステータスです。詳細については、「変更追跡ソリューションの概要」をご参照ください。

注意事項

  • 追跡する必要がある単一行のデータが 16 MB を超えると、コンシューマークライアントでメモリ不足(OOM)が発生する可能性があります。

  • 変更追跡インスタンスは最大 20 のコンシューマーグループを作成でき、データの繰り返し追跡が可能です。

  • コンシューマーグループは、データ追跡を実行するコンシューマーを 1 つだけ作成できます。

  • DTS は、DStore モジュールまたはクライアントを使用して増分データを読み取ります。モジュールまたはクライアントを切り替えると、データの重複が発生する可能性があります。

手順

  1. 変更追跡タスクページに移動します。

    1. Data Management (DMS) コンソール にログインします。

    2. 上部のナビゲーションバーで、ポインターを [データ + AI] に移動します。

    3. [DTS (DTS)] > [変更追跡] を選択します。

    説明
  2. ターゲットの追跡インスタンスを見つけて、インスタンス ID をクリックします。

  3. 左側のナビゲーションウィンドウで [データ消費] をクリックします。

  4. [データ消費] ページで、左上隅にある [コンシューマーグループの作成] をクリックします。

  5. ポップアップの コンシューマーグループの追加 ダイアログボックスで、コンシューマーグループ情報を設定します。

    構成

    説明

    コンシューマーグループ名

    必要に応じて、コンシューマーグループ名を変更できます。後で簡単に識別できるように、ビジネス上の意味を持つ名前を構成することをお勧めします。

    アカウント

    コンシューマーグループのアカウント情報を設定します。

    • ユーザー名には、大文字、小文字、数字、アンダースコア(_)の 1 つ以上を含めることができます。

    • ユーザー名は 16 文字を超えることはできません。

    パスワード

    コンシューマーグループアカウントに対応するパスワード情報を設定します。

    • パスワードには、大文字、小文字、数字、特殊文字のうち少なくとも 2 つを含める必要があります。

    • パスワードは 8 ~ 32 文字である必要があります。

    パスワードの確認

    同じパスワードをもう一度入力します。

  6. [確認] をクリックします。

次の手順

コンシューマーグループを作成した後、ソースデータベースの種類、コンシューマークライアントの種類などの要因に基づいてデータ消費方法を選択します。

消費方法

該当するデータベースの種類

手順

SDK を使用して PolarDB-X 1.0 サブスクリプションデータを消費する

PolarDB-X 1.0DMS LogicDB

この方法は、データベースの種類が PolarDB-X 1.0 または DMS LogicDB のサブスクリプションインスタンスに適しています。

説明

データベースの種類が PolarDB-X 1.0 または DMS LogicDB のサブスクリプションインスタンスは、この消費方法のみをサポートしています。

SDK を使用してサブスクリプションデータを消費する

MySQLPolarDB for MySQLPostgreSQLOraclePolarDB (Oracle と互換性)PolarDB for PostgreSQLPolarDB-X 2.0

ほとんどのシナリオで推奨されます。

説明

データベースの種類の要件を満たすサブスクリプションインスタンスには、この消費方法をお勧めします。

Flink-DTS-Connector を使用してサブスクリプションデータを消費する

分散ストリーム処理フレームワーク Apache Flink を使用するシナリオに最適です。

Kafka クライアントを使用してサブスクリプションデータを消費する

既存の Kafka クライアントと社内ソースコード開発機能があるシナリオに適しています。