Muhammet Orazov

Thanks @hugogu for the PR! I have added some comments, please have a look. Do you know why the CI is failing?

Looks good, thanks @hugogu for quick update! Hopefully the CI is green this time 🤞

Thanks @dongwoo6kim , Tests looks good from my side 👍 (_Recently I faced similar issue which maybe related, when running batch mode with setting `startingOffsets`. The change should solve that...

Hey @dongwoo6kim, we created another [issue](https://issues.apache.org/jira/browse/FLINK-35565) for it, the solution seems to be similar but let's discuss it again once this PR is merged.

Thanks @dongwoo6kim, Looks good!

Hello @victor09091, @MartijnVisser, Any update on this issue? Otherwise I'd happy to continue the work and finish the migration. Please let me know 👍

@ianoc Thanks for the feedback. Yes, I agree. It makes perfect sense to start suffix with "/". However, I am not quite sure how to put require/assert for that. I...

Thanks @XComp, I am going to address your suggestions. Please have a look once you are back

@flinkbot run azure

Thanks @XComp, going through your suggestions, I will address them, thanks 👍 No indeed, I am going to squash them, it should be single commit in the end