Hao Yu created FLINK-38249:
------------------------------
Summary: Flink CDC should let users configure Debezium’s
'skipped.operations' parameter to filter out unwanted binlog operations.
Key: FLINK-38249
URL: https://issues.apache.org/jira/browse/FLINK-38249
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.4.0, cdc-3.3.0, cdc-3.2.0, cdc-3.1.0
Reporter: Hao Yu
In some scenarios, users may want to filter out certain delete
operations. This configuration allows Debezium to filter these operations,
helping meet user requirements while reducing serialization overhead.
So Flink CDC can meet user requirements by setting this parameter.
Debezium can set 'skipped.operations' to filter some operations.
{code:java}
//代码占位符
public static final Field SKIPPED_OPERATIONS =
Field.create("skipped.operations")
.withDisplayName("skipped Operations")
.withType(Type.LIST)
.withGroup(Field.createGroupEntry(Field.Group.ADVANCED, 11))
.withWidth(Width.SHORT)
.withImportance(Importance.LOW)
.withValidation(CommonConnectorConfig::validateSkippedOperation)
.withDescription(
"The comma-separated list of operations to skip during
streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes, 't' for truncates, and 'none' to indicate nothing skipped. "
+ "By default, no operations will be skipped.");
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
