3.2.4.4. トピック名
PostgreSQL コネクターは、すべての挿入、更新、および削除のイベントを単一の Kafka トピックに対して書き込みます。デフォルトでは、Kafka トピック名は serverName. schemaName. tableName です。serverName は database.server.name
設定プロパティーで指定されたコネクターの論理名、schemaName は 操作が発生したデータベーススキーマの名前、tableName は操作が発生したデータベーステーブルの名前です。
たとえば、postgres
データベースと、、、およびの 4 つのテーブルを含む inventory
スキーマを使用した PostgreSQL インストールについて考え products
products_on_hand
customers
てみましょう orders
。このデータベースに論理サーバー名が指定された場合 fulfillment
、コネクターは以下の 4 つの Kafka トピックでイベントを生成します。
-
fulfillment.inventory.products
-
fulfillment.inventory.products_on_hand
-
fulfillment.inventory.customers
-
fulfillment.inventory.orders
一方、テーブルは特定のスキーマの一部ではなく、デフォルトの public
PostgreSQL スキーマで作成された場合、Kafka トピックの名前は以下のようになります。
-
fulfillment.public.products
-
fulfillment.public.products_on_hand
-
fulfillment.public.customers
-
fulfillment.public.orders