Skip to content

Commit 64ebdb7

Browse files
authored
[Docs] update debezium json document (#6652)
1 parent 50c6c94 commit 64ebdb7

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

Diff for: docs/en/connector-v2/formats/debezium-json.md

+7
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,12 @@ The MySQL products table has 4 columns (id, name, description and weight).
6868
The above JSON message is an update change event on the products table where the weight value of the row with id = 111 is changed from 5.18 to 5.15.
6969
Assuming the messages have been synchronized to Kafka topic products_binlog, then we can use the following Seatunnel conf to consume this topic and interpret the change events by Debezium format.
7070

71+
**In this config, you must specify the `schema` and `debezium_record_include_schema` options **
72+
- `schema` should same with your table format
73+
- if your json data contains `schema` field, `debezium_record_include_schema` should be true, and if your json data doesn't contains `schema` field, `debezium_record_include_schema` should be false
74+
- `{"schema" : {}, "payload": { "before" : {}, "after": {} ... } }` --> `true`
75+
- `{"before" : {}, "after": {} ... }` --> `false`
76+
7177
```bash
7278
env {
7379
parallelism = 1
@@ -88,6 +94,7 @@ source {
8894
weight = "string"
8995
}
9096
}
97+
debezium_record_include_schema = false
9198
format = debezium_json
9299
}
93100

0 commit comments

Comments
 (0)