7.2.4. Debezium PostgreSQL の変更イベントレコードを受信する Kafka トピックのデフォルト名
PostgreSQL コネクターは、単一テーブルのすべての挿入、更新、および削除操作をのイベントを単一の Kafka トピックに書き込みます。デフォルトでは、serverName.schemaName.tableName です。
-
ServerName は、
database.server.nameコネクター設定プロパティーで指定したコネクターの論理名です。 - SchemaName は、操作が発生したデータベーススキーマの名前です。
- tableName は、操作が発生したデータベーステーブルの名前です。
たとえば、対応する と、PostgreSQL インストールの変更をキャプチャーするコネクターの設定の論理サーバー名で、postgres データベースがあり、product、product_on_hand 、 お客様、および順序の 4 つのテーブルが含まれる インベントリー スキーマ があるとします。コネクターは以下の 4 つの Kafka トピックにレコードをストリーミングします。
-
fulfillment.inventory.products -
fulfillment.inventory.products_on_hand -
fulfillment.inventory.customers -
fulfillment.inventory.orders
テーブルは特定のスキーマの一部ではなく、デフォルトのパブリック PostgreSQL スキーマで作成されたとします。Kafka トピックの名前は以下になります。
-
fulfillment.public.products -
fulfillment.public.products_on_hand -
fulfillment.public.customers -
fulfillment.public.orders