Ashish Khatkar

[Bug] A single bad message can cause Flink CDC writer to stuck in an infinite loop waiting for the schema change

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version 0.9.0 ### Compute Engine Flink 1.18.1 ### Minimal reproduce step You can...

[common][flink] Add support for complex types in kafka debezium avro cdc action

2

### Purpose @umeshdangat has an outstanding PR which was updated after PR by @zhuangchong was merged. That PR: https://github.com/apache/paimon/pull/3323 The above patch allows consuming data from avro data from kafka...