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)
