3.2.4.6.2. イベントの値の変更
変更イベントメッセージの値は、より複雑です。メッセージキーと同様に、schema セクションと payload セクションがあります。PostgreSQL コネクターによって生成されるすべての変更イベント値の payload セクションには、以下のフィールドが含まれる 構造 があります。
-
opは、操作のタイプを記述する文字列の値が含まれる必須フィールドです。PostgreSQL コネクターの値はccreate(または insert)、u更新、d削除、およびr読み取り(スナップショットの場合)になります。 -
beforeはオプションのフィールドで、イベント発生 前 の行の状態がある場合はその行の状態になります。この構造は、PostgreSQL_serverコネクターがpublic.customersテーブルのすべての行に使用するPostgreSQL_server.public.customers.ValueKafka Connect スキーマによって記述されます。
警告
このフィールドが利用できるかどうかは、各テーブルの REPLICA IDENTITY 設定に大きく依存します。
-
afterはオプションのフィールドで、イベント発生 後 の行の状態が含まれる場合です。構造は、で使用される同じPostgreSQL_server.public.customers.ValueKafka Connect スキーマによって記述されbeforeます。 -
sourceは、イベントのソースメタデータを記述する構造が含まれる必須フィールドです。ここでは、PostgreSQL のフィールドには、Debezium バージョン、コネクター名、影響を受けるデータベースの名前、スキーマ、およびテーブルが含まれます。イベントが継続中のスナップショットの一部であるかどうか、レコードの メタ情報 セクションから同じフィールドが含まれるかどうか。 -
ts_msは任意で、コネクターがイベントを処理した JVM のシステムクロックを使用して(Kafka Connect タスクを実行している JVM でシステムクロックを使用)。
当然ながら、イベントメッセージ値の スキーマ 部分には、この構造と内部のネストされたフィールドを記述するスキーマが含まれます。