Flink connector 是否支持忽略delete message

咨询下各位大佬，请问下connector现在有支持忽略delete消息的选项配置


吗？比如上游的数据是一个upsert/retract流，在connector这里是否有选项去忽略delete
message,当作append流只去戳里insert消息。我看现在代码没有类似的功能，不确定是否有相关的jira或者实现

回复