解析RocketMQ的消息索引文件consumequeue

CommitLog的文件結構 下圖展示了CommitLog的文件結構,可以看到,包含了topic、queueId、消息體等核心信息。 同Kafka一樣,消息是變長的,順序寫入。 如下圖所示: ConsumeQueue的文件結構 ConsumeQueue中並不需要存儲消息的內容,而存儲的是消息在CommitLog中的offset。也就是說,ConsumeQueue其實是CommitLog的一個索引文
相關文章
相關標籤/搜索