如何搞定Kafka重复消费?

如何保证 Kafka 消息不重复消费?我们在做开发的时候为了程序的健壮性,在使用 Kafka 的时候一般都会设置重试的次数,但是因为网络的一些原因,设置了重试就有可能导致有些消息重复发送了(当然导致消息重复也有可能是其他原因),那么怎么解决消息重复这个问题呢?关于这个问题,我这儿提供了如下三种解决方案,供大家参考。 解决方案 方案一 / 保存并查询 给每个消息都设置一个独一无二的 key,消费的时
相关文章
相关标签/搜索