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 035c91a3cc [ISSUE #9763] Fix invalid user disable status check in
authorization (#9764)
add 2eb21293cf [ISSUE #9773] Implement Shared RocksDB Instance for Broker
Configs (#9774)
No new revisions were added by this update.
Summary of changes:
.../LocalAuthenticationMetadataProvider.java | 36 ++--
.../LocalAuthorizationMetadataProvider.java | 39 ++--
.../{ => config/v1}/RocksDBConfigManager.java | 77 +++++--
.../config/v1/RocksDBConsumerOffsetManager.java | 164 +++++++++++++--
.../config/v1/RocksDBSubscriptionGroupManager.java | 222 ++++++++++++++++++---
.../config/v1/RocksDBTopicConfigManager.java | 146 +++++++++++++-
.../broker/offset/ConsumerOffsetManager.java | 13 +-
.../rocketmq/broker/topic/TopicConfigManager.java | 2 +-
.../RocksDBConsumerOffsetManagerMigrationTest.java | 147 ++++++++++++++
...cksDBSubscriptionGroupManagerMigrationTest.java | 155 ++++++++++++++
.../v1/RocksDBTopicConfigManagerMigrationTest.java | 149 ++++++++++++++
.../offset/RocksDBConsumerOffsetManagerTest.java | 5 +-
.../RocksDBLmqConsumerOffsetManagerTest.java | 2 +-
.../org/apache/rocketmq/common/BrokerConfig.java | 14 ++
.../common/config/AbstractRocksDBStorage.java | 23 ++-
.../common/config/ConfigRocksDBStorage.java | 180 +++++++++++------
.../metadata/RocksDBConfigToJsonCommand.java | 35 +++-
17 files changed, 1220 insertions(+), 189 deletions(-)
rename broker/src/main/java/org/apache/rocketmq/broker/{ =>
config/v1}/RocksDBConfigManager.java (63%)
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManagerMigrationTest.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManagerMigrationTest.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManagerMigrationTest.java