3.2.4.4. トピック名

PostgreSQL コネクターは、すべての挿入、更新、および削除のイベントを単一の Kafka トピックに対して書き込みます。デフォルトでは、Kafka トピック名は serverName. schemaName. tableName です。serverNamedatabase.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