5.2.3. Debezium SQL Server 変更イベントレコードを受信する Kafka トピックのデフォルト名
SQL Server コネクターは、特定のテーブルの INSERT
、UPDATE
、DELETE
操作すべてのイベントを単一の Kafka トピックに書き込みます。デフォルトでは、Kafka トピック名は serverName.schemaName.tableName の形式を取ります。以下のリストは、デフォルト名のコンポーネントの定義を示しています。
- serverName
-
database.server.name
設定プロパティーで指定したコネクターの論理名です。 - schemaName
- 変更イベントが発生したデータベーススキーマの名前。
- tableName
- 変更イベントが発生したデータベーステーブルの名前。
たとえば、fulfillment
が SQL Server インストールの変更をキャプチャーするコネクターの設定の論理サーバー名であるとします。サーバーには、スキーマ名 dbo
の inventory
データベースがあり、データベースには 製品
、products_on_hand
、customers
の名前を持つテーブルが含まれ ます
。コネクターは以下の Kafka トピックにレコードをストリーミングします。
-
fulfillment.dbo.products
-
fulfillment.dbo.products_on_hand
-
fulfillment.dbo.customers
-
fulfillment.dbo.orders
デフォルトのトピック名が要件を満たさない場合は、カスタムトピック名を設定できます。カスタムトピック名を設定するには、論理トピックルーティング SMT に正規表現を指定します。論理トピックルーティング SMT を使用してトピックの命名をカスタマイズする方法は、指定したトピックへの Debezium イベントレコードのルーティング を参照してください。