消息队列MQ

Kafka的消息不丢失

本文主要是介绍Kafka的消息不丢失，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

（1）Broke消息不丢失：因为有副卡relicas的存在，会不断地从leader中同步副本，索引一个broker崩溃，不会导致说话间丢失，除非只有一个副本。

（2）生产者消息不丢失：ACK机制（配置为All/-1），配置0或1可能会存在丢失。

（3）消费者消费不丢失：重点控制offset

  • At-least once:一种数据可能会重复消费。
  • Exactly-once：仅被消费一次。
这篇关于Kafka的消息不丢失的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
栏目导航