大家好

       请问目前flink sql是不是不能没有开启全局端到端精确一致性(eos)的方
式,

目前仅有kafka实现了TwoPhaseCommitSinkFunction,但kafka的ddl中也没有属性去设
置Semantic为EXACTLY_ONCE

 

我们是否可以去支持更多的事务性connector,并可以在flink sql维度支持开启全局的
端到端一致性,并为每个connector是否支持EXACTLY_ONCE进行验证,

当开启全局EXACTLY_ONCE并且所有使用的connector都支持EXACTLY_ONCE,是否整个应
用程序就可以做到端到端的精确一致性

Reply via email to