Hi @Ferenc Csaky , Apologies for the late reply. I had already conducted overall API compatibility verification earlier, but had been hesitant to submit a formal PR due to concerns about module design (to avoid introducing a large number of new modules and new code). I recently discovered that using the shade plugin can effectively reduce code rewriting. I have provided an implementation https://github.com/apache/flink-cdc/pull/4294 in the community, and I hope you can help provide some suggestions on module partitioning and API adaptation. If you have implemented code or changes you would like to make, you are also welcome to propose them.

@kunni thanks for the response, i'll check this in the next couple days!