Custom Slink Source Example

A simple flink source implementation that produce sequential integers. The implementation supports checkpointing and able to restart from the state.

The source is created specifically for a block post. You can read the details here.