I am new this tool . We are replicating data from PG to kenisus using Debezium. I do see columns defined in below format from kenisis streams
- type: struct
fields:
- type: int32
optional: false
field: scale
- type: bytes
optional: false
field: value
optional: false
name: io.debezium.data.VariableScaleDecimal
version: 1
doc: Variable scaled decimal
field: rate
and payload containing in this format
rate:
scale: 4
value: G7Y=
Actual value defined in PG as "0.7094"
Now i am trying to read this information from kenisis streams and save into parquet file
can someone point me how to analyze the data content ?