Flink CDC Issue Import created FLINK-34766: ----------------------------------------------
Summary: Ensure checkpointing is enabled for Postgres connector Key: FLINK-34766 URL: https://issues.apache.org/jira/browse/FLINK-34766 Project: Flink Issue Type: Improvement Components: Flink CDC Reporter: Flink CDC Issue Import **Is your feature request related to a problem? Please describe.** Yes, it is: when not enabling checkpointing with the Debezium-based Postgres connector, then the replication slot in the database will never be advanced (as this is triggered by committing offsets in Debezium, which in turn is triggered by checkpointing in Flink CDC), causing WAL to be retained indefinitely. **Describe the solution you'd like** Raise a warning or even an exception when using this connector without checkpointing. **Describe alternatives you've considered** n/a ---------------- Imported from GitHub ---------------- Url: https://github.com/apache/flink-cdc/issues/1866 Created by: [gunnarmorling|https://github.com/gunnarmorling] Labels: enhancement, Assignee: [gunnarmorling|https://github.com/gunnarmorling] Created at: Tue Jan 10 20:43:21 CST 2023 State: open -- This message was sent by Atlassian Jira (v8.20.10#820010)