Tagged: exactly once

Kafka在可靠性这一块有很灵活的配置，我们可以根据自己的应用需求来设置相应的参数，有时候我们希望Kafka不要丢失message，但是不在意是否有重复的message，这个时候也许at least once的保证就足够了。当然对于我们通常来说的producer产生message，consumer消费message的应用来说，处理重复message还是很容易的，比如通过一些unique的id来进行判断是否是重复的信息等，但对于stream的process，比如说计算一些信息的平均值，这种process就很难去一个个看是否有重复的message了，这个时候就希望Kafka能够保证不要有重复的信息，这也就是本文要来聊一聊的Exactly once保证。 我们来简单想一想，如果让你来做，怎么才能做到exactly...