1 个回答
以kafka为例，在flink中如果要实现端到端精准一次，作为Source可以重发，由Flink维护offset，作为状态存储，指定隔离级别为READ_COMMITTED才不会消费到未正式提交的数据，避免重复。作为Sink官方的实现类是基于两阶段提交，能保证写入的Exactly-Once，需要指定sink的语义为Exactly-Once生效。
发布于：3个月前 (02-06) IP属地：四川省
我来回答
您需要 登录 后回答此问题！