flink-cdc
flink-cdc copied to clipboard
[FLINK-35129][cdc][postgres] Add checkpoint cycle option for commit offsets
https://issues.apache.org/jira/browse/FLINK-35129
- Adds option for checkpoint cycle parameter
- Commits PG offsets on every multiple of checkpoint cycle
- Updates docs with new parameter definition
- [TODO] Adds unit & integration tests to cover new functionality