This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch dledger-controller-brokerId
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from c5474b33a [ISSUE#5045] Refactor the register and elect-master process
in controller mode (#5046)
add 46869c9e9 [ISSUE #5876] fix resource leak in
DefaultLitePullConsumerTest
add 5a43f1d5e [ISSUE #5921] Support domain resolution to obtain the
controller address (#5922)
add ae9f11943 [ISSUE #5916] Fix availableNamesrvAddrMap can not remove old
nameserver address (#5917)
add 0ea930182 GetSyncStateSetSubCommand can also print that the broker is
not in syncStateSet (#5935)
add bcaebf19e Bump rocketmq-logging to 1.0.1 (#5946)
add 39dafc248 [ISSUE #5949] Remove TopicQueueMappingInfo class duplicate
licenses (#5950)
add bb03bf608 Upgrade maven assembly plugin version to 3.4.2 (#5951)
add 1e7c861c1 [ISSUE #5929] Fix the issue that broker send heartbeat to
controller frequently causing thread blocking when the network partition (#5930)
add e2a341e7f Calculate retry message throughput in pop consumption mode
(#5954)
new bf9e6b6e7 Merge branch 'develop' into dledger-controller-brokerId
new 90c147689 Resolve the conflict
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/rocketmq/broker/BrokerController.java | 2 +-
.../broker/controller/ReplicasManager.java | 66 +++++-
.../apache/rocketmq/broker/out/BrokerOuterAPI.java | 8 +-
.../broker/processor/PopMessageProcessor.java | 18 +-
.../apache/rocketmq/broker/BrokerOuterAPITest.java | 2 +-
.../broker/controller/ReplicasManagerTest.java | 1 +
.../rocketmq/client/impl/MQClientAPIImpl.java | 6 +-
.../impl/consumer/DefaultMQPushConsumerImpl.java | 16 +-
.../consumer/DefaultLitePullConsumerTest.java | 226 ++++++++++++---------
.../org/apache/rocketmq/common/BrokerConfig.java | 10 +
.../impl/manager/ReplicasInfoManager.java | 24 ++-
.../impl/manager/ReplicasInfoManagerTest.java | 6 +-
pom.xml | 4 +-
.../apache/rocketmq/remoting/RemotingClient.java | 2 +
.../remoting/netty/NettyRemotingClient.java | 29 ++-
...nSyncStateData.java => BrokerReplicasInfo.java} | 60 +++---
.../statictopic/TopicQueueMappingInfo.java | 16 --
.../rocketmq/tools/admin/DefaultMQAdminExt.java | 4 +-
.../tools/admin/DefaultMQAdminExtImpl.java | 4 +-
.../apache/rocketmq/tools/admin/MQAdminExt.java | 4 +-
.../command/ha/GetSyncStateSetSubCommand.java | 23 ++-
21 files changed, 332 insertions(+), 199 deletions(-)
rename
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/{InSyncStateData.java
=> BrokerReplicasInfo.java} (59%)
