mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-30 18:10:44 +08:00
c3c6832f35
* feat: improve rocksdb compaction filter factory resource management - Refactor ConsumeQueueCompactionFilterFactory to use LongSupplier instead of MessageStore - Add proper resource cleanup in ConsumeQueueRocksDBStorage.preShutdown() - Update RocksDBOptionsFactory to accept external compaction filter factory - Optimize write buffer size for CQ rocksdb performance This change improves resource management and reduces memory leaks by: 1. Decoupling compaction filter from MessageStore reference 2. Ensuring proper cleanup of native resources 3. Making compaction filter factory lifecycle manageable * Polish the code * Fix consumeQueueCompactionFilterFactory not use