変更追跡では、コンシューマーグループを作成できます。複数のコンシューマーグループを作成することで、同じデータソースからデータを繰り返し消費でき、変更追跡の使用コストを削減できます。
前提条件
変更追跡インスタンスが作成され、そのステータスは 通常 です。詳細については、「変更追跡シナリオの概要」をご参照ください。
使用上の注意
-
消費対象の単一行データが 16 MB を超えると、コンシューマークライアントでメモリ不足 (OOM) エラーが発生する可能性があります。
-
1 つの変更追跡インスタンスに対して最大 20 のコンシューマーグループを作成して、データを繰り返し消費できます。
-
各コンシューマーグループは 1 つのコンシューマーのみをサポートします。そのコンシューマーがグループのすべてのデータを消費します。
-
DStore モジュールまたはクライアントを切り替えると、データが重複する可能性があります。
手順
- [追跡タスクの変更] ページに移動します。
- にログインします。 データ管理 (DMS) コンソール
- 上部のナビゲーションバーで、[DTS] をクリックします。
- 左側のナビゲーションウィンドウで、 を選択します。
説明- 実際の動作は、DMSのモードおよびレイアウトに応じて変化し得る。 詳細については、「シンプルモード」および「DMSコンソールのレイアウトとスタイルのカスタマイズ」をご参照ください。
- 新しいDTSコンソールの [追跡の変更] ページに移動することもできます。
-
対象の変更追跡インスタンスを見つけ、そのインスタンス ID をクリックします。
-
左側のナビゲーションペインで、データ消費 をクリックします。
-
データ消費 ページで、左上隅の コンシューマーグループの追加 をクリックします。
-
コンシューマーグループの追加 ダイアログボックスで、次のパラメーターを設定します。
パラメーター
説明
[コンシューマーグループ名]
識別しやすいように、内容がわかる名前を推奨します。
[アカウント]
コンシューマーグループのアカウントを入力します。
-
アカウント名には、大文字、小文字、数字、アンダースコア (_) を使用できます。
-
アカウント名の長さは 1~16 文字である必要があります。
[パスワード]
アカウントのパスワードを入力します。
-
パスワードには、大文字、小文字、数字、特殊文字のうち、少なくとも 2 種類を含める必要があります。
-
パスワードの長さは 8~32 文字である必要があります。
[パスワードの確認]
同じパスワードを再度入力します。
-
-
確かですか をクリックします。
次のステップ
コンシューマーグループを追加した後、ソースデータベースのタイプとコンシューマークライアントのタイプに基づいて消費方法を選択します。
|
消費方法 |
対象データベースタイプ |
説明 |
|
[PolarDB-X 1.0]、[DMS LogicDB] |
この方法は、ソースデータベースが PolarDB-X 1.0 または DMS LogicDB である変更追跡インスタンス用です。 説明
これは、ソースデータベースが PolarDB-X 1.0 または DMS LogicDB である変更追跡インスタンスでサポートされている唯一の消費方法です。 |
|
|
[MySQL]、[PolarDB for MySQL]、[PostgreSQL]、[Oracle]、[PolarDB (Oracle と互換性)]、[PolarDB for PostgreSQL]、[PolarDB-X 2.0] |
この方法は、ほとんどのシナリオに適しています。 説明
この方法は、サポートされているすべてのデータベースタイプで推奨されます。 |
|
|
この方法は、Apache Flink ストリーム処理フレームワークを使用するシナリオ向けです。 |
||
|
この方法は、独自の Kafka クライアントを持ち、ソースコードから開発できるユーザー向けです。 |