RocketMQ源码分析 broker启动，commitlog、consumequeue、indexfile、MappedFileQueue、MappedFile之间的关系以及位置说明
目录 1.MappedFile类属性说明 1.1.MappedFile类属性如下 1.2.MappedFile构造器说明 2.MappedF ...
原文：rocketmq的broker恢复commit-log的时候如何恢复consumeQueue、indexfile
如果一个broker正常退出，是会删除abort文件的。那么启动broker的时候发现abort文件还存在，那么说明上次是异常终止，会进入到commit log的recoverAbnormally逻辑里面，因为所有其他的信息都是从commit log获取到的，所以追根溯源只能从commit log开始着手。 public void recoverAbnormally long maxPhyOffs ...
2019-12-08 22:28 2 202 推荐指数：
相关推荐
RocketMQ架构原理解析（三）：消息索引（ConsumeQueue & IndexFile）
RocketMQ架构原理解析（一）：整体架构 RocketMQ架构原理解析（二）：消息存储（CommitLog） RocketMQ架构原理解析（三）：消息索引（ConsumeQueue & IndexFile） RocketMQ架构原理解析（四）：消息生产端（Producer） 一、概述 ...
RocketMQ中的CommitLog、ConsumeQueue、indexFile、offsetTable以及多种偏移量对比
CommitLog消息内容原文的存储文件，同Kafka一样，消息是变长的，顺序写入，生成规则：每个文件的默认1G =1024 * 1024 * 1024，commitlog的文件名fileName，名 ...
快速弄明白RocketMQ的CommitLog、ConsumeQueue、indexFile、offsetTable 以及多种偏移量对比
CommitLog 消息内容原文的存储文件，同Kafka一样，消息是变长的，顺序写入 生成规则： 每个文件的默认1G =1024 * 1024 * 1024，commitlog的文件名f ...
RocketMQ：(2) Broker
Broker是RocketMQ的核心，大部分“重量级”工作都是由Broker完成的，包括接收Producer发过来的信息、处理Consumer的消费消息请求、消息的持久化存储、消息的HA机制以及服务端过滤功能等。 一、消息存储文件 分布式队列因为有高可靠性的要求，所以数据要通过磁盘进行 ...
git commit或pull后恢复到原来版本
https://blog.csdn.net/litao31415/article/details/87713712 ...
假如Kafka集群中一个broker宕机无法恢复，应该如何处理？
假如Kafka集群中一个broker宕机无法恢复, 应该如何处理? 今天面试时遇到这个问题, 网上资料说添加新的broker, 是不会自动同步旧数据的. 笨办法 环境介绍 三个broker的集群, zk,kafka装在一起 创建测试topic 查看 注意当前 ...
git 如何恢复只是提交到本地的文件（或者commit）
今天早上傻逼了，把四天的代码commit到了本地，然后fetch一下，然后就全没了，不过git还是挺强大的 参考：http://blog.163.com/jiams_wang/blog/static/3033914920138179326885/ git如何恢复本地删除的文件(还没执行 git ...