退订

退订

回复：（无主题）

退订 | | hello | | yangx...@163.com | Signature is customized by Netease Mail Master 在2021年04月06日 11:46，郭华威 写道： 退订

回复： 回复：fink新增计算逻辑时kafka从头开始追平消费记录

Hi 苟刚： 另外，看了你的计算逻辑，是同一份数据源里面，有不同类型的数据需要分开处理，你可以尝试使用Flink的侧输出来做分流处理，这样逻辑更清晰，而且程序效率也会高许多 | | ss | | yangx...@163.com | 签名由网易邮箱大师定制 在2020年4月7日 19:54，LakeShen 写道： Hi 苟刚， Flink 任务中，如果开启 Checkpoint 的话，会在每次Checkpoint 完成后，提交偏移量。如果没有开启的话，就是根据自动提交来提交偏移量，默认是开启的，间隔是 5 s.