common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java

common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java
store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java

common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java
store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java

common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java
store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java

common/src/main/java/org/apache/rocketmq/common/config/ConfigHelper.java
store/src/main/java/org/apache/rocketmq/store/rocksdb/RocksDBOptionsFactory.java

common/src/main/java/org/apache/rocketmq/common/config/ConfigRocksDBStorage.java
store/src/main/java/org/apache/rocketmq/store/rocksdb/ConsumeQueueRocksDBStorage.java