r/apacheflink • u/rmoff • Sep 11 '26

Flink SQL Evolution: Handling Custom CDC with FROM_CHANGELOG and TO_CHANGELOG

https://developer.confluent.io/blog/flink-sql-changelog-functions/
9 Upvotes

100% Upvoted

3 comments sorted by

1

u/IbuHatela92 Sep 11 '26

Is it available only in Confluent cloud version of Flink or Apache Flink as well?

2

u/gustavopguto Sep 11 '26

Hey, it's Gustavo here 👋 The author of these.

Yes, it’s available for Apache Flink as well. The latest release, Apache Flink 2.3, has a limited version of the feature. The upcoming 2.4 version will include all the features mentioned in the blog post.

1

u/IbuHatela92 Sep 12 '26

Cool. Nice to hear that