This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 91fdc35db3 Fix the permission check for retry topic to get topic
route. (#9073)
add 35a6426ea9 [ISSUE #9025] [RIP-73] Pop Consumption Improvement Based on
RocksDB (#9048)
No new revisions were added by this update.
Summary of changes:
broker/BUILD.bazel | 1 +
.../apache/rocketmq/broker/BrokerController.java | 26 +-
.../rocketmq/broker/pop/PopConsumerCache.java | 303 +++++++++
.../rocketmq/broker/pop/PopConsumerContext.java | 177 +++++
.../rocketmq/broker/pop/PopConsumerKVStore.java | 58 ++
.../broker/pop/PopConsumerLockService.java | 100 +++
.../rocketmq/broker/pop/PopConsumerRecord.java | 211 ++++++
.../broker/pop/PopConsumerRocksdbStore.java | 174 +++++
.../rocketmq/broker/pop/PopConsumerService.java | 714 +++++++++++++++++++++
.../broker/processor/AckMessageProcessor.java | 143 ++++-
.../broker/processor/AdminBrokerProcessor.java | 20 +
.../processor/ChangeInvisibleTimeProcessor.java | 72 ++-
.../broker/processor/NotificationProcessor.java | 14 +-
.../broker/processor/PopBufferMergeService.java | 8 +-
.../broker/processor/PopMessageProcessor.java | 209 ++++--
.../rocketmq/broker/pop/PopConsumerCacheTest.java | 144 +++++
.../broker/pop/PopConsumerContextTest.java | 69 ++
.../broker/pop/PopConsumerLockServiceTest.java | 60 ++
.../rocketmq/broker/pop/PopConsumerRecordTest.java | 75 +++
.../broker/pop/PopConsumerRocksdbStoreTest.java | 102 +++
.../broker/pop/PopConsumerServiceTest.java | 416 ++++++++++++
broker/src/test/resources/rmq.logback-test.xml | 9 +-
.../rocketmq/client/impl/MQClientAPIImpl.java | 12 +
.../org/apache/rocketmq/common/BrokerConfig.java | 54 ++
.../rocketmq/remoting/protocol/RequestCode.java | 1 +
.../rocketmq/tools/admin/DefaultMQAdminExt.java | 6 +
.../tools/admin/DefaultMQAdminExtImpl.java | 6 +
.../apache/rocketmq/tools/admin/MQAdminExt.java | 3 +
.../rocketmq/tools/command/MQAdminStartup.java | 2 +
.../command/export/ExportPopRecordCommand.java | 110 ++++
30 files changed, 3227 insertions(+), 72 deletions(-)
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerCache.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerContext.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerKVStore.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerLockService.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerCacheTest.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerContextTest.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerLockServiceTest.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerRecordTest.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStoreTest.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerServiceTest.java
create mode 100644
tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportPopRecordCommand.java
