Lindorm:データサブスクリプション用のプッシュチャンネルの作成

前提条件

開始する前に、以下をご確認ください。

• ご利用の Lindorm インスタンスのホワイトリストに、Lindorm クライアントと Message Queue for Apache Kafka クライアントの IP アドレスを追加済みであること。詳細については、「ホワイトリストの設定」をご参照ください。

• ソースの Lindorm インスタンスと送信先の Message Queue for Apache Kafka インスタンスを Lindorm Tunnel Service (LTS) に接続済みであること。詳細については、「ネットワーク接続」をご参照ください。

• LindormTable データソースを作成済みであること。詳細については、「LindormTable データソースの追加」をご参照ください。

• Kafka データソースを作成済みであること。詳細については、「Kafka データソースの追加」をご参照ください。

• 変更追跡機能を有効にしました。詳細については、「変更追跡の有効化」をご参照ください。

Lindorm ストリームの作成

1. お使いの Lindorm インスタンスの LTS ウェブユーザーインターフェース (UI) にログインします。 左側のナビゲーションウィンドウで、[変更データキャプチャ] > [プッシュ] を選択します。

   

2. [作成] をクリックし、次の表で説明されているパラメーターを設定します。

   パラメーター	説明	型	デフォルト値
   Lindorm クラスター	作成済みの LindormTable データソースを選択します。	—	—
   テーブル名	名前空間.テーブル名 の形式で、増分データをサブスクライブするテーブル名を入力します。例： ns1.table1 は、ns1 名前空間内の table1 をサブスクライブします。ns2.* は、ns2 名前空間内のすべてのテーブルをサブスクライブします。	String	—
   ストリーム設定 – key_only	プライマリキーの値のみをエクスポートする場合は、true に設定します。	ブール値	false
   ストリーム設定 – order_output	挿入、削除、更新操作をプライマリキーの値に基づいてシーケンス順に記録する場合は、true に設定します。	ブール値	false
   MessageStorage 型	KAFKA を選択します。	—	—
   ストレージデータソース	作成済みの Kafka データソースを選択します。	—	—
   MessageStorage 設定 – kafka_topic	変更追跡データを配信する Message Queue for Apache Kafka の Topic 名を入力します。	String	—
   MessageVersion	ストリームレコードのデータ形式です。	String	DebeziumV1
   メッセージ設定 – old_image	各ストリームレコードに、操作**前の**行データを含める場合は、true に設定します。有効化すると、UPDATE および DELETE レコードには元のフィールド値が含まれます。false に設定した場合、操作前の行データはストリームレコードに含まれません。	ブール値	true
   メッセージ設定 – new_image	各ストリームレコードに、操作**後の**行データを含める場合は、true に設定します。有効化すると、INSERT および UPDATE レコードには結果として得られるフィールド値が含まれます。	ブール値	true

   

3. [確定] をクリックします。