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

Data Transmission Service:コンシューマーグループの追加

最終更新日:Aug 22, 2026

変更追跡では、コンシューマーグループを作成できます。複数のコンシューマーグループを作成することで、同じデータソースからデータを繰り返し消費でき、変更追跡の使用コストを削減できます。

前提条件

変更追跡インスタンスが作成され、そのステータスは 通常 です。詳細については、「変更追跡シナリオの概要」をご参照ください。

使用上の注意

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

  • 1 つの変更追跡インスタンスに対して最大 20 のコンシューマーグループを作成して、データを繰り返し消費できます。

  • 各コンシューマーグループは 1 つのコンシューマーのみをサポートします。そのコンシューマーがグループのすべてのデータを消費します。

  • DStore モジュールまたはクライアントを切り替えると、データが重複する可能性があります。

手順

  1. [追跡タスクの変更] ページに移動します。
    1. にログインします。 データ管理 (DMS) コンソール
    2. 上部のナビゲーションバーで、[DTS] をクリックします。
    3. 左側のナビゲーションウィンドウで、[DTS (DTS)] > [追跡の変更] を選択します。
    説明
  2. 対象の変更追跡インスタンスを見つけ、そのインスタンス ID をクリックします。

  3. 左側のナビゲーションペインで、データ消費 をクリックします。

  4. データ消費 ページで、左上隅の コンシューマーグループの追加 をクリックします。

  5. コンシューマーグループの追加 ダイアログボックスで、次のパラメーターを設定します。

    パラメーター

    説明

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

    識別しやすいように、内容がわかる名前を推奨します。

    [アカウント]

    コンシューマーグループのアカウントを入力します。

    • アカウント名には、大文字、小文字、数字、アンダースコア (_) を使用できます。

    • アカウント名の長さは 1~16 文字である必要があります。

    [パスワード]

    アカウントのパスワードを入力します。

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

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

    [パスワードの確認]

    同じパスワードを再度入力します。

  6. 確かですか をクリックします。

次のステップ

コンシューマーグループを追加した後、ソースデータベースのタイプとコンシューマークライアントのタイプに基づいて消費方法を選択します。

消費方法

対象データベースタイプ

説明

SDK を使用した PolarDB-X 1.0 インスタンスからのデータ消費

[PolarDB-X 1.0]、[DMS LogicDB]

この方法は、ソースデータベースが PolarDB-X 1.0 または DMS LogicDB である変更追跡インスタンス用です。

説明

これは、ソースデータベースが PolarDB-X 1.0 または DMS LogicDB である変更追跡インスタンスでサポートされている唯一の消費方法です。

SDK を使用したデータ消費

[MySQL]、[PolarDB for MySQL]、[PostgreSQL]、[Oracle]、[PolarDB (Oracle と互換性)]、[PolarDB for PostgreSQL]、[PolarDB-X 2.0]

この方法は、ほとんどのシナリオに適しています。

説明

この方法は、サポートされているすべてのデータベースタイプで推奨されます。

flink-dts-connector を使用したデータ消費

この方法は、Apache Flink ストリーム処理フレームワークを使用するシナリオ向けです。

Kafka クライアントを使用したデータ消費

この方法は、独自の Kafka クライアントを持ち、ソースコードから開発できるユーザー向けです。