このトピックでは、Lindorm ストリームを使用してプッシュ モードでデータ サブスクリプションを実装する方法について説明します。Lindorm データベースのテーブルに Lindorm ストリームを作成すると、そのテーブルの変更追跡機能が有効になります。変更追跡機能は、テーブルに対して実行される各データの挿入、更新、および削除操作を記録します。記録された操作に含まれる増分データは、Lindorm ストリームの作成時に指定した Message Queue for Apache Kafka トピックにプッシュされます。その後、増分データを使用して、要件に基づいてビジネス サービスを構築または実装できます。
プロセス
次の図は、Lindorm テーブルの増分データのメッセージが Message Queue for Apache Kafka にプッシュされる方法を示しています。
前提条件
Lindorm クライアントと Message Queue for Apache Kafka クライアントの IP アドレスが、Lindorm インスタンスのホワイトリストに追加されていること。詳細については、「ホワイトリストを構成する」をご参照ください。
ソース Lindorm インスタンスと宛先 Message Queue for Apache Kafka インスタンスが Lindorm Tunnel Service（LTS）に接続されていること。詳細については、「ネットワーク接続」をご参照ください。
LindormTable データ ソースが作成されていること。詳細については、「LindormTable データ ソースを追加する」をご参照ください。
Kafkaデータソースが作成されます。詳細については、「Kafkaデータソースの追加」をご参照ください。
変更追跡機能が有効になっていること。詳細については、「変更追跡を有効にする」をご参照ください。
Lindorm ストリームを作成する
Lindorm インスタンスの LTS Web ユーザー インターフェース（UI）にログインします。左側のナビゲーション ペインで、[変更データ キャプチャ] > [プッシュ] を選択します。
表示されるページで、[作成] をクリックします。次に、次の表に示すパラメーターを構成します。
パラメーター
説明
Lindorm クラスター
作成済みの LindormTable データ ソースを選択します。
テーブル名
サブスクライブする増分データが格納されているテーブルの名前を入力します。テーブル名は、Namespace.Table 名の形式で入力します。次の例は、テーブル名を指定する方法を示しています。
ns1.table1: ns1 名前空間の table1 テーブルを指定します。
ns2.*: ns2 名前空間のすべてのテーブルを指定します。
ストリーム設定
key_only: プライマリ キーの値のみをエクスポートするかどうかを指定します。デフォルト値: false。order_output: プライマリ キーの値に基づいて、挿入、削除、および更新操作をシーケンスで記録するかどうかを指定します。デフォルト値: false。
メッセージ ストレージ タイプ
KAFKA を選択します。
ストレージ データ ソース
作成済みの Kafka データ ソースを選択します。
メッセージ ストレージ設定
kafka_topic: 追跡データの送信先の Message Queue for Apache Kafka トピックの名前を指定します。メッセージ バージョン
データ形式。デフォルト値: DebeziumV1。
メッセージ設定
old_image: 挿入、更新、および削除操作が実行される前に 行に格納されているデータを、Lindorm が操作に対して生成するストリーム レコードに含めるかどうかを指定します。デフォルト値: true。new_image: 挿入、更新、および削除操作が実行された 後に 行に格納されているデータを、Lindorm が操作に対して生成するストリーム レコードに含めるかどうかを指定します。デフォルト値: true。
[コミット] をクリックします。