当 leader 收到合法数量 follower 的 ACKs 后,就向各个 follower 广播 COMMIT 命令,同时也会在本地执行 COMMIT 并向连接的客户端返回「成功」。但是如果在各个 follower 在收到 COMMIT 命令前 leader 就挂了,导致剩下的服务器并没有执行都这条消息。

图中的C2就是一个典型的例子,在集群正常运行过程的某一个时刻,Server1是leader服务器,先后广播了消息P1、P2、C1、P3和C2.其中当leader服务器把消息C2(Commit事务proposal2)发出后就立即崩溃退出了,那么针对这种情况,ZAB协议就需要确保事务Proposal2最终能够在所有的服务器上都能被提交成功,否则将会出现不一致

已经被处理的消息不能丢相关推荐

  1. 消息队列把消息弄丢了怎么办?

    消息队列会丢失消息吗? 答案是肯定的,所以对于业务严谨的数据,我们要确保其在消息队列中的安全,不能丢. 要想解决不丢的问题,首先要弄清楚 消息是怎么丢的呢? 丢消息的关键点有3个: Producer ...

  2. 消息队列把消息弄丢了怎么办

    消息队列把消息弄丢了怎么办 消息队列会丢失消息吗? 答案是肯定的,所以对于业务严谨的数据,我们要确保其在消息队列中的安全,不能丢. 要想解决不丢的问题,首先要弄清楚 消息是怎么丢的呢? 丢消息的关键点 ...

  3. Go语言如何操纵Kafka才能保证消息不丢?

    背景 目前一些互联网公司会使用消息队列来做核心业务,因为是核心业务,所以对数据的最后一致性比较敏感,如果中间出现数据丢失,就会引来用户的投诉,年底绩效就变成325了.之前和几个朋友聊天,他们的公司都在 ...

  4. 给你1分钟,回答下RabbitMQ如何保证消息不丢?

    一条消费成功被消费经历了生产者->MQ->消费者,因此在这三个步骤中都有可能造成消息丢失. 一 消息生产者没有把消息成功发送到MQ 1.1 事务机制 AMQP协议提供了事务机制,在投递消息 ...

  5. 面试官问:Kafka 会不会丢消息?怎么处理的?

    点击上方蓝色"方志朋",选择"设为星标" 回复"666"获取独家整理的学习资料! Kafka存在丢消息的问题,消息丢失会发生在Broker, ...

  6. Kafka如果丢了消息,怎么处理的?

    点击上方蓝色"程序猿DD",选择"设为星标" 回复"资源"获取独家整理的学习资料! 作者 | Dong GuoChao 来源 | https ...

  7. kafka发送mysql数据丢失_Kafka 如果丢了消息,怎么处理的?

    Kafka存在丢消息的问题,消息丢失会发生在Broker,Producer和Consumer三种. Broker Broker丢失消息是由于Kafka本身的原因造成的,kafka为了得到更高的性能和吞 ...

  8. kafka消息处理失败后如何处理_面试题:Kafka 会不会丢消息?怎么处理的?

    Kafka存在丢消息的问题,消息丢失会发生在Broker,Producer和Consumer三种. Broker Broker丢失消息是由于Kafka本身的原因造成的,kafka为了得到更高的性能和吞 ...

  9. 返回的图片 buffer 怎么接收_面试题:Kafka 会不会丢消息?怎么处理的?

    Kafka存在丢消息的问题,消息丢失会发生在Broker,Producer和Consumer三种. Broker Broker丢失消息是由于Kafka本身的原因造成的,kafka为了得到更高的性能和吞 ...

最新文章

  1. TensorFlow(1)TensorFlow基础(整体介绍)
  2. 内存存储器和外存储器的异同
  3. Spark Shuffle两种Manager
  4. linux 文件批量转utf8
  5. Java和SAP ABAP的异常处理
  6. DNS 错误事件4000 4013
  7. asp adodb连接mysql数据库语句_ASP连接MySQL数据库的方法
  8. Javascript php 异常捕获
  9. 各种不同服务器301重定向设置代码大全
  10. 中国企业如何实施5s管理体系
  11. 实现MySQL读写分离---maxscale代理服务器配置(详解)
  12. 前后端鉴权之session-cookie
  13. hdu6080(FLOYD)
  14. php 输入经纬度查询位置,php 根据实际地址获取对应的经纬度
  15. 至简设计系列_7段数码管显示
  16. 怎样做音乐相册?简单又好看的音乐相册怎么做?
  17. slf4j的包使用说明
  18. 一种获取公网ip地址并发送邮件至指定邮箱的实现方法
  19. 局部刷新的两种实现方式
  20. POJ 1417 True Liars 带权并查集 + 背包

热门文章

  1. 一步步学习汇编系列(7)
  2. HikariConfig配置详解
  3. 老板和主管不懂SEO,乱给SEO人员下指令怎么办?
  4. JS - 讨论 - 编码习惯 - JavaScript代码到底要不要写分号?
  5. Codeforces 712C. Memory and De-Evolution
  6. 免费开源分布式系统日志收集框架 Exceptionless
  7. 让表单文本框只读不可编辑的方法
  8. 23天的单车旅行,从广州到四川,篇首语
  9. 集合对象的声明和初始化
  10. Android焦点问题