简直崩溃了, 新增或减少一个系统, 我们都要去修改系统A的代码, 而且我们还需要考虑调用的系统挂掉了怎么办, 是否要将数据存起来, 是否要重发等等, 这是非常不合理的一种设计, 我们需要引入消息队列....•partition主从副本数据同步
生产者发布消息到某个分区时, 先通过ZooKeeper找到该分区的leader副本, 然后将消息只发送给leader副本, leader副本收到消息后将其写入本地磁盘...”的异常, 这样便知道集群控制器已存在....分区重平衡
消费者重启或宕机
这两个原因都会导致消费者在消费消息后没有提交offset.
(2) 解决办法
这个问题只能通过业务手段来解决, 比如我们在消费前先查询数据库, 判断是否已消费(status...= 1), 或消费后在Redis中做个记录, 下次消费前先从Redis中判断是否已消费.