購読対象の変更
ダウンロード
フォーカスモード
フォントサイズ
操作シナリオ
購読タスクの開始後、ユーザーが購読対象を追加または削除する必要がある場合は、この操作を通じて行うことができます。
購読タイプを変更し、購読対象を追加または削除します。
Kafkaパーティションポリシーを変更し、カスタムパーティションポリシーを設定します。
前提条件
データ購読 Kafka版を作成しました。
注意事項
1. 購読対象を変更した後も、元の内部ネットワークアドレスは変更されず、引き続きその購読タスクにバインドされています。内部ネットワークアドレスは、購読詳細の表示 > 購読情報で確認できます。
2. 購読対象を変更した後、購読タスクが再起動され、秒単位の一時停止が発生します。再起動後、システムはソースデータベースのBinlog中断位置を認識して購読を継続するため、データが中断されることはありません。
3. MySQL/TDSQL-C MySQL/MariaDB/Percona/TDSQL PostgreSQLの購読タスクでは、購読対象を変更するとタスクが再起動され、再起動後にユーザーがkafkaクライアントでデータを消費する際に重複が発生する可能性があります。MongoDBの購読タスクでは、再起動後にデータの重複は発生しません。
MySQL/TDSQL-C MySQL/MariaDB/Percona/TDSQL PostgreSQLの購読タスクでは、DTSは最小データ単位で伝送を行います。各checkpoint位置が1つのデータ単位としてマークされます。再起動時に、ちょうど1つのデータ単位の伝送が完了している場合は、データの重複は発生しません。再起動時に、1つのデータ単位がまだ伝送中である場合は、再度起動した後にこのデータ単位を再取得してデータの整合性を確保するため、データの重複が発生します。
MySQL/TDSQL-C MySQLは現在データ重複排除をサポートしており、消費Demoには重複排除ロジックが含まれているため、データの重複は発生しません。MariaDB/Percona/TDSQL PostgreSQLでは、重複データが気になる場合は、データ消費時に重複排除ロジックを設定してください。
4. オブジェクトを追加した後、購読されるデータ内容は、タスク再起動後にソースデータベースで生成された増分データを対象としています。
操作手順
1. DTSコンソールにログインし、左側のナビゲーションでデータ購読を選択して、データ購読ページに進みます。
2. データ購読リストで、変更するデータ購読を選択し、操作列の詳細 > 購読対象の変更を選択して、購読対象変更ページに進みます。
3. 購読対象変更ページで、購読タイプを再選択し、購読対象をチェックするか、またはパーティションポリシーを変更し、タスクの設定をクリックします。
4. 購読リストに戻ると、購読タスクは開始中の状態になり、タスクの事前チェックと初期化が行われます。開始が成功すると、購読タスクは実行状態になり、Kafkaクライアントを使用して購読データを消費できます。
フィードバック