spark streaming写到redis中进行累加操作，这个应该是at least one语义吧？

Question

有两个问题
1.spark streaming写到redis中进行累加操作，这个应该是at least one语义吧？
2.采用structured streaming的话，有statestore机制，可以直接hset幂等写入redis，这是精确一次语义吧？

Answer 1

Michael_PK 2022-03-13 19:20:23

ss sss都是能保证at least once的，这个没啥好奇的，关键是要exactly once，这个要从offset的角度去评判