看了这个文档,我的starrocks使用的主键模型。 在MySQL删除数据会同步删除starrocks数据。但是我不想捕捉删除操作,只需要捕捉MySQL的insert和update。
找到了,使用 debezium 的 skipped.operations 配置。
在flink mysql cdc connector中加配置
‘debezium.skipped.operations’=‘d’
看了这个文档,我的starrocks使用的主键模型。 在MySQL删除数据会同步删除starrocks数据。但是我不想捕捉删除操作,只需要捕捉MySQL的insert和update。
找到了,使用 debezium 的 skipped.operations 配置。
在flink mysql cdc connector中加配置
‘debezium.skipped.operations’=‘d’