We are using CDC pipeline to stream data from oracle DB to S3 in Avro format.
We are able to stream to the data from oracle to kafka with debezium connector and we are able to flatten the data and store it as avro file in s3 but the problem is when we try to replace the flattened records i.e from ‘after_field_one’ to ‘field_one’ it just never happens.
Please help us with conf that should solve this issue of ours please.