4.4.7. トランザクションメタデータ
Debezium は、トランザクションメタデータ境界を表すイベントを生成でき、データメッセージをエンリッチできます。
4.4.7.1. トランザクション境界
Debezium は、すべてのトランザクションの BEGIN および END のイベントを生成します。各イベントに以下が含まれます。
-
status:BEGINまたはEND -
id- 一意のトランザクション識別子の文字列表現。 -
event_count(ENDイベント用) - トランザクションによって出力されるイベントの合計数 -
data_collections(ENDイベントの場合): 指定のデータコレクションからの変更によって出力されたイベントの数を提供するdata_collectionとevent_countのペアの配列。
以下は、メッセージの内容の例です。
{
"status": "BEGIN",
"id": "1462833718356672513",
"event_count": null,
"data_collections": null
}
{
"status": "END",
"id": "1462833718356672513",
"event_count": 2,
"data_collections": [
{
"data_collection": "rs0.testDB.tablea",
"event_count": 1
},
{
"data_collection": "rs0.testDB.tableb",
"event_count": 1
}
]
}
トランザクションイベントは、<database.server.name>.transaction という名前のトピックに書き込まれます。
