Amazing, congrats!
Thanks for your efforts!
Best,
Muhammet
On 2024-05-17 09:32, Qingsheng Ren wrote:
The Apache Flink community is very happy to announce the release of
Apache Flink CDC 3.1.0.
Apache Flink CDC is a distributed data integration tool for real time
data and batch data, bringing
Hey Jacob,
If you understand how the Kafka offset managed in the checkpoint,
then you could map this notion to other Flink sources.
I would suggest to read the Data Sources[1] document and FLIP-27[5].
Each source should define a `Split`, then it is `SourceReaderBase`[2]
class' responsibility to
