This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 0f878b5157 [maven-release-plugin] prepare for next development
iteration
add 975b4f1f82 [ISSUE #6103] Add AsyncAppender support for client logging
add cce65a685e [ISSUE #6112] Fix typos in RemoteAddressStrategyFactory
add 70495270f4 [ISSUE #6101] Remove rebundant code
add 4cc3311590 [ISSUE #6123] Fix flaky test in tiered storage (#6124)
add c4c3c61f22 Temporarily cancel the protection of the master branch
(#6139)
add b24682619c Ignore AutoSwitchRoleIntegrationTest temporarily because it
is still flaky (#6144)
add 076941407a [ISSUE #6092] fix: wrong brokerConfigPath when init
configuration
add 260a21fa4f [ISSUE #6147] Detach RocketmqTraffic from
controller_default log (#6148)
add 70a5675e2e [ISSUE #6138] Skip log empty remoting code distribution
(#6136)
add 68ec1afb2e [ISSUE #6140]Use apache/rocketmq-ci docker repo in CI
(#6135)
add 6f115385bb [ISSUE #6149] remove handle when exceed renewMaxTimeMillis
(#6150)
add eda205b46f [ISSUE #6141] validate group when auto create subscription
group (#6142)
add e3d173bbc5 [ISSUE #6087] fix typos (#6091)
add 2dff070a77 [ISSUE #6138] Add back the protection of the master branch
(#6143)
add 2e69a05fa5 [ISSUE #6159] fix typos
add 0ec8c92a97 Match apache actions policy, use apache/rocketmq-test-tool
in workflow
add bf11311135 [ISSUE #6057] Modify magic number code
add 527350decf Polish the unified remoting logger name.
add 7cfffe7f48 [ISSUE #6163] Fix the issue of infinite retry of order
message (#6164)
add e421c1a3ed [ISSUE #6180] Polish the issue_template (#6181)
add 487473eb74 [ISSUE #6121] Optimize some code style in store module
(#6122)
add d6310dfdad [ISSUE #6117] Optimize NettyRemotingServer EventLoopGroup
create (#6118)
add e3a591b483 raplace HashedWheelTimer
add f1adb115c3 Optimize the timer implementation in Remoting
add aeebe5e97b Optimize the timer implementation in Remoting
add 3bdab84c58 Optimize the timer implementation in Remoting
add 254deb079a Command line tool QueryMsgByKey& QueryMsgTraceById：time
range and number of data bars can be specified
add 72f458bccd Optimize command line tools QueryMsgByKey& QueryMsgTraceById
add 473e23b1dd Optimize command line tools QueryMsgByKey& QueryMsgTraceById
add 2f93cbe051 Optimize getQueueIdByBroker naming ambiguity
add 90bf886340 [ISSUE #6192] Set a default value when UniqID is empty in
Proxy (#6193)
add ed849142f5 proxy some optimization (#6175)
add 7a454477c5 [ISSUE #6194] The config enableControllerMode and
enableDLegerCommitLog cannot both be true (#6195)
add 8667a0d335 [ISSUE #6119] replace ScheduleMessageService method
reference
add 84ed06158a [ISSUE #6131] Simplified ConsumeReviveObj code (#6132)
add f712bc873e [ISSUE #6185]Fix It does not take effect when acl is
enabled in the proxy
add 086f9d130b remove invalid null check code (#6183)
add 33371e5d8e [ISSUE #6145] Modify Collections.sort usage (#6146)
add 88000dac21 [ISSUE #6196] Update lastConsumeTimestamp and
lastPullTimestamp in DefaultLitePullConsumer (#6197)
add 19ad6f4392 doc:add rocketmq-eventbridge to README.md (#6221)
add 543c118200 [ISSUE #6060] Optimize AutoSwitchRoleBase#nextPort method
(#6068)
add d5d5a637f6 [ISSUE #6226] Shutdown flowMonitor when connection
disconnect (#6227)
add 44a1694d1a [ISSUE #6244] Fix issue template feature request order
incorrect (#6245)
add ce99a7fe8a [ISSUE #6246] Optimize AcceptSocketService#run
add 18fcce664c [ISSUE #6250] Fix wrong value of
MessageStoreConfig#storePathEpochFile
add cc8823cf62 [ISSUE #5883] DLedger commit log should override the
getData (#5879)
add b9bbd52060 [ISSUE #6230] Optimizes ScheduleMessageService code and
logic (#6231)
add c9975961f8 Remove uncompatible sed in runserver.sh
add 9214c69d83 Remove unnecessary property[append] for ConsoleAppender
add 236d4a164e Apply AsyncAppender for broker
add 4af6c768fc [ISSUE #6157] Fix incompatibility between 4.x and 5.x in
message trace
add 2b42e16480 [ISSUE #6266] get MessageId from UNIQ_KEY firstly when
build system message (#6267)
add afe6781be6 Remove rbe_default digest check
add 1986c6bdf9 [ISSUE #6207] Use static subscription to calculate consumer
lag and latency
add 98d8988abc [ISSUE #6133]Update the version information to 5.1.0 in
README.md (#6134)
add 61c4ba5009 [ISSUE #6213] fix: when subscriptionGroupConfig is null ,we
do not register consumer
add 9e0fb1b029 [ISSUE #6169] Fix NPE when timerWheel disabled (#6184)
add 5c45294c45 [ISSUE #6189] Replace ThreadFactory create (#6190)
add 390070159b [ISSUE #6235] Removed the ForwardRequestProcessors class
that is not being used
add ba4dd5a21e [ISSUE #6283] Fix the bug that single replica cannot flush
data when transientStorePoolEnable is true
add 244e8f9158 [ISSUE #6285] Polish the DLedgerControllerStateMachine log
output to help troubleshoot
add e599187047 add GET_CONSUMER_CONNECTION_LIST
add 7b23042eb2 [ISSUE #6306] Fix unexpected state from slave (#6307)
add 3c770c95ce [ISSUE #6302] Fix DefaultMQPushConsumerImpl code style
(#6303)
add 9a7d095eac Upgrade dledger version to 0.3.1.1 (#6319)
add d0df0518c7 [ISSUE #6308]Fix docs (#6301)
add 20dc5c96ea [ISSUE #6316] Nameserver should choose a master with a
larger epoch when there are two masters in controller mode (#6317)
add 47355d115d [ISSUE #6272]Add judgment for SendLatencyFault in
MQFaultStrategy#selectOneMessageQueue (#6273)
add 2cc899fc35 [ISSUE #5663] Fix Messages may be lost when SyncStateSet
expand in extreme scenarios (#5798)
add 0732f125f9 Fixed the proxy configuration path null value problem
(#6311)
add 37ff93a27b [ISSUE #6331] Optimlize DefaultMQPushConsumerImpl#subscribe
method (#6332)
add a1de567e11 [ISSUE#5045] Refactor the register and elect-master process
in controller mode (#5046)
add 2c2db61e32 Resolve the conflict
add e38ea9510a feat(controller): refactor broker's information recording
core from ip address to broker id
add 9577aacbc0 feat(controller): add protocols about new register flow
add f750dec0c7 refactor code in module: store/ha for persistence broker-id
add cfdfa0ea51 feat(broker): implement the general register to controller
protocol
add d7cac1582e feat(controller): implement the general register to
controller protocol in controller side
add a808727768 feat(controller): implement logic about dealing with
UpdateBrokerAddress event
add b97801c855 feat(controller): Improved logic and adaptation testing for
persistent broker id versions
add c9bf9d7899 feat(broker): perfect logic test in broker
add 1293b74153 feat(broker): perfect ReplicaManagerTest.java
add 11b2cb84a6 feat(broker): fix some bugs to successfully compile project
add 01469030e4 fix(controller): fix some bug about wrong type comparison
add ea71dc545a fix(controller): fix some bug about ignoring new-add event
type
add f843851788 fix(controller): fix some bug to pass
AutoSwitchRoleIntegrationTest
add 03d6ba23e4 style(controller): remove unused import
add 3a69aae701 [ISSUE #6023] Add a unit test to verify new register
process in broker with controller mode (#6024)
add 0c2f480c3a fix(broker): mark unless attribute with @Deprecated
add 46668b4eaf test(broker): add test to verify broker restart with
changed address
add c494a43c52 refactor(controller): optimize some code suggested by
reviewer
add 5460c77622 test(test): add
AutoSwitchRoleIntegration#testBasicWorkWhenControllerShutdown
add 358128c078 fix(controller): return failure when receive a heartbeat
with empty brokerId
add 92fac4c10f fix(store): fix wrong value of
MessageStoreConfig#storePathMetadata and storePathTempMetadata
add 2515ea5f98 fix(admin): print masterBrokerId when calling
GetSyncStateSet
add 1ad1c4d825 docs(docs): add docs about how to update to BrokerId version
add 5a2aea7997 refactor(controller): remove meaningless attribute
`MessageStoreConfig#storePathTempMetadata`
add 697e4e4264 feat(broker): check metadata if valid when register
add 3a141868b7 Fix some typos and log output
add b8f3de444a fix(broker): set isolate's value to false to normally
register broker to name server
add bbf54f8a71 Modify StorePathMetadata to StorePathBrokerIdentity
add d145f36286 feat(broker): Random sleep within one second when broker
register failed
add 3bad20c37a Make random an object variable
add 578a42803c Fix bug that state not match when handshake
add 28618e95ab Polish the code structure and code style
add c8bc4e84a0 Rename cleanBrokerData subCommand to cleanBrokerMetadata
add 498ffbb938 refactor(broker): rename registerSuccess to
registerBrokerToController
add 935e6d573d test(broker): fix forgetting set the changed cluster name
broker config back to default value
add ce418c907c feat(broker): add more logs when broker register to
controller
add 175ec4b1ae fix(broker): fix wrong log
add 19eafc80ff fix(broker): fix wrong test
add c94c65b691 fix(admin): fix incompatible command: CleanBrokerMeta
add e14158c7ff fix(controller): fix forgetting initialize
BrokerHeartbeatManager
add a240753951 Fix CleanControllerBrokerMetaSubCommand and
ReElectMasterSubCommand parameter error
add 506a8a9037 test(controller): add more logs when register and refactor
ReplicasManagerRegisterTest
add 600d873fba test(controller): try to fix flaky test
add 10147debf5 test(broker): optimize some test base store path
add d802231163 fix(store): fix conflicts after rebase
add dcf51d715c test(broker): fix conflicts in test after rebase
add 483ba12cae test(controller): To pass `ControllerManagerTest` in
Windows, we forbid the controller to notify the brokers when their roles have
been changed.
add fac699ea4d Fix some spelling problems
add 22a7ec6b63 [ISSUE #6333] Simplify the logic of the
FilterAPI#buildSubscriptionData method (#6334)
add acc3b89e30 [ISSUE #6328] fix ConfigurationManagerTest (#6329)
add ba00ff8b79 [ISSUE #6339] set message's flag in popRevive (#6340)
add 95299c05e9 [ISSUE #6268] fix rocketmq-proxy does not work properly in
k8s nodePort mode (#6262)
add 1c98a2316f [ISSUE #6215]make benchmark cover compress msg situation
(#6216)
add 7485d3cbef [ISSUE #6313] com.google.guava version upgraded
add 5fd07d8aa7 Add logging exporter for metrics
add f34743217c Fix parameter in metrics exporter
add 6a42102bc3 fix bazel test
add 57dd002fab Update WORKSPACE
add 616885ce17 Added jul to slf4j bridge
add 52c4c0cdf6 [ISSUE #6346] Support asynchronously notify brokers when
their roles has been changed (#6348)
add 94db42ade7 [ISSUE #6292] fix typos (#6293)
add 4a4626df63 [ISSUE #6343] fix consumeQueueExtDir not deleted when
deleting topic (#6351)
add 3db8d039d1 [ISSUE #6347] fix: use mutable list to avoid start fail
when enable tiered store
add 63a014b810 [ISSUE#6342] Local SyncStatSet sync to remote value when
changeToMaster (#6352)
add 6fd1bb9a28 [ISSUE #6358] Add chinese docs about
persistent-unique-broker-id (#6359)
add 667ebbcc14 ReceiptHandleProcessor message renewal strategy
optimization #6232
add 06a87e6504 ReceiptHandleProcessor message renewal strategy
optimization #6232
add fce64608b1 ReceiptHandleProcessor message renewal strategy
optimization #6232
add 1e3e7638f3 ReceiptHandleProcessor message renewal strategy
optimization #6232
add feb1f3077a ReceiptHandleProcessor message renewal strategy optimization
add 877f146f56 ReceiptHandleProcessor message renewal strategy optimization
add 10d17cfaee [ISSUE #6287] Fixed two redundant judgments (#6288)
add 4e0a723d22 [ISSUE #6344] queueOffsets in topicQueueTable rollback when
master changes to master in ha mode (#6345)
add 5ac91199f2 [ISSUE #6380] Optimize switch cases in BrokerOuterAPI.
(#6381)
add 7dbcdc8f96 [ISSUE #6372] new scheduledExecutor clean consume queue
(#6376)
add 3613821c6a [ISSUE #6365] fix no log in benchmark (#6366)
add 7d67484456 [ISSUE #6390] Add break to the exception of
WHEEL_TIMER_NOT_ENABLE. (#6394)
add c05a0b222c [ISSUE #6377] Polish the code when broker change to master
(#6378)
add 3f8cf890ff [ISSUE #6026] Fix the problem that the custom JAVA_HOME
environment variable does not take effect (#6167)
add 68362151a2 [ISSUE #6396] Fix DefaultMQPushConsumer javadoc typo (#6397)
add f1e02e8947 [ISSUE #6392] GetSyncStateSet prints replica's alive status
(#6393)
add 38ce7c891d [ISSUE #6408] Due to network issues, use new ASK cluster in
VIRGINA to run e2e test (#6409)
add d75ab111f3 [ISSUE #6406] Add more visual comments on IndexFile &
IndexHeader & ConsumeQueue
add f2614f62c8 [ISSUE #6419] DLedger new version to fix problem in issue
282 (#6418)
add cafc9ac3de [ISSUE #6421] Fix the encode bug.
add c5fec3af41 [ISSUE #6402]opt transaction message check (#6401)
add 1e2a301266 [ISSUE #6382] Periodically check for inactive masters
(#6383)
add c17baf1e33 [ISSUE #6386] Some improvements for compactionTopic (#6387)
add e3b5f07ae8 [ISSUE #6438] Optimizing the memory usage of
MultiProtocolRemotingServer (#6439)
add b41d1ddf35 [ISSUE #6373] Optimized log printing and fixed null pointer
exceptions (#6375)
add 59c82d9976 [ISSUE #6449] Fix NPE in MultiProtocolRemotingServer (#6450)
add fe0a0a0789 [ISSUE #6440] Optimize the code of consumer thread name,and
support tag the name of scheduledExecutor thread. (#6441)
add 9b97eaf5ba [ISSUE #6424] Make topicConfig updating atomically
add 91ccfeb2f4 When the proxy starts, the log displays the configuration
details (#6453)
add a7a86382f0 [ISSUE #6454] Fix unsafe shutdown process in tiered storage
(#6455)
add 0faa0a2c7d [ISSUE #6414] polish
MQClientAPIImpl.getDefaultTopicRouteInfoFromName… (#6452)
add 1818c2d507 [ISSUE #4890] BugFix: fix binary search consume offset by
time (#6429)
add 8c4568569c Add rpc validatation for gRPC in PlainAccessResource (#6460)
add 8aa7bc08f7 [ISSUE #6400] Remove unnecessary config
BrokerConfig.maxDelayTime
add 8ddf2fdd42 [ISSUE #6469]Translation persistent_unique_broker_id.md
(CN->EN) (#6470)
add eb804014f1 [ISSUE #6466] Add ForbiddenType when Broker process
PullMessage return no permission
add 6662f2a86d build(deps): bump spring-core from 5.3.23 to 5.3.26 (#6464)
add 4da7b1884b [ISSUE #6474]Optimize ServiceThread log print (#6475)
add ca927600d3 [ISSUE #6390] Add break to the exception of
WHEEL_TIMER_NOT_ENABLE. (#6477)
add cc9321db49 [ISSUE #6462] Optimize PushConsumer code and logic (#6463)
add 654c12ed56 [ISSUE #6430] Scan topic.json to find compactionTopic and
copy it
add 9b90b5b70a [ISSUE #6445] Fix the attribute of the compaction topic doc
(#6451)
add 9ccfcfbd13 [ISSUE #6478] Fix outTPS in mqadmin when using
compactionTopic
add 054ee473fd [ISSUE #6482]style: Rename the variable "filepath" to
"filePath" on line 55 of PosixFileSegment.java
add a96f672338 [ISSUE #6484] Revert inappropriate modification
add 1eebed8e95 [ISSUE #6488] Use ServiceThread#shutdown to replace the
deprecated ServiceThread#stop method (#6489)
add e0213fb192 [ISSUE #6321] Optimize yaml parse code (#6322)
add 17aa86c618 [ISSUE #6324] Improving compact topic stability (#6353)
add 8b5853d0c3 [ISSUE #6263] use true address from channel
add 77cb5ce672 [ISSUE #6492] Polish persistent unique broker id document
(#6493)
add 59b49dee31 [ISSUE #6203] Allow to publish delay message with arbitrary
timestamp (#6204)
add cbd1d38199 flush() in compactionTopic (#6498)
add 0d516ba708 [ISSUE #6473] Fix multi dispatch error when
enableMultiDispatch=true and enableLmq=true (#6476)
add ec5c199b90 [ISSUE #6501] Replace deprecated
DLedgerServer#getdLedgerStore method (#6502)
add 24bc8c9092 Only enable the squash button when merging a pull request
(#6504)
add 526a107557 [ISSUE #6508] Prohibit writing and reading before
confirming the broker role in ha mode (#6509)
add e7f29798ec [ISSUE #6518] Fix bug that multi-threaded using bytebuffer
add 66cf564c67 [ISSUE #6523] Schematic diagram of adding BatchConsumeQueue
storage unit (#6524)
add 72befa0fb4 1. change the compactionTopic dispatch process from
asynchronous to synchronous (#6530)
add a258a301d4 [ISSUE #6436] Fix broker boot succes but get wrong ip
address (#6437)
add 9574165fe3 [ISSUE #6299] Remove TimerFlushService#run duplicate code
(#6300)
add e55e5e204d Temporary removal of required maven-compile status check
(#6561)
add 465bfcf802 Upgrade the image to the latest version (#6562)
add cb53fa572e remove (#6564)
add 7dc9942fe2 [ISSUE #6547] Some RemotingChannel calls need to be
forwarded to the original Channel (#6548)
add f44a1c3fd5 Update the image of bazel-build to ubuntu-latest (#6569)
add 938b5bb929 [ISSUE #6581]Add a description of the Apache RocketMQ E2E
repository in README.md (#6582)
add baad0a427f [ISSUE #6579] Prevent the properties of trace message from
exceeding the maximum value of short (#6580)
add d9a7315ffe [ISSUE #6584] Fix AppendMessageCallback comments typo
(#6585)
add d34a28bb31 [ISSUE #6513] fix(proxy): enhance ProxyContext (#6522)
add d3a8fe0c5b [ISSUE #6587] fix getMax() in SparseConsumeQueue
add d1b14b0ff9 [ISSUE #6525]Make ConsumeQueueInterface extends from
FileQueueLifeCycle (#6534)
add 3fe81bfbac [ISSUE #6545] Remove getTopicConfigs method in interface
MessageStore (#6531)
add ca006ca9ab [ISSUE #6591] Fix Starting nameserver and broker failed
because the default java command in Darwin contained Spaces (#6592)
add b3868ab606 (fix): logback config path seperator and brokerLogDir
default value m… (#6590)
add f9f7147676 [ISSUE #6612] Prevent redundant validator in
accessValidatorList (#6615)
add 8aad756550 build(deps): bump spring-core from 5.3.26 to 5.3.27 (#6604)
add 073da6b971 Fix the issue broker startup failed when version upgrade
from 5.1.0 to latest develop because compactionThreadNum is 0 (#6611)
add ea8b9d9f7a [ISSUE #6594] skip verification for admin user (#6613)
add af6a95f4c5 [ISSUE #6627] Fix ConsumerLagCalculator#processAllGroup
retry topic NPE (#6628)
add 14ad16b0d5 [ISSUE #6634] Polish the HA logs to better troubleshoot
issues (#6635)
add 652f5bbba9 [ISSUE #6627] Fix ConsumerLagCalculator NPE if group or
topic is null (#6632)
add fad3dece7b [ISSUE #6537] Fix bug MessageStoreConfig.haListenPort item
config not… (#6538)
add e3b8178871 [ISSUE #6570] Fix the issue that expectLogicOffset is
greater than currentLogicOffset in consumeQueue build when the message is
illegal (#6641)
add 7bb061158b [ISSUE #6648]: Fix the bug that not all message fetch
requests are processed via TieredStorage when level is FORCE (#6649)
add b00c82cacc Rewrite the issue/pull request template of RocketMQ (#6645)
add dcf7ccdd9b [ISSUE# 6650]: Fix using the deprecated method
`MessgaeStore#checkInDiskByConsumeOffset` (#6651)
add 23a8ed490f [ISSUE #6644] Add admin client future interface (#6646)
add bcbb25fddc [ISSUE #6660] Fix semaphoreAsyncSendSize init error (#6661)
add 7903c70412 [ISSUE #6662] Optimize the process of HA's confirmOffset
calculation (#6663)
add b4e6acca32 [ISSUE #6686] Remove ClientManageProcessor#heartBeat repeat
judgment (#6687)
add b410557e87 [ISSUE #6609] Fix the issue that consume queue building
exceeds confirmOffset when node restarts to recover (#6618)
add 709537595c [ISSUE #6665] Optimize the process of truncateInvalidMsgs()
(#6666)
add 6f6032e9eb [ISSUE #6673]Issue template enhancements (#6674)
add 57642bc630 [ISSUE #6691] Support reentrant pop orderly for broker
(#6692)
add d9223ffd78 Update AclUtils.java (#6689)
add 2da6e9b2d6 [ISSUE #6696] Refector proxy common and client module
(#6697)
add 6770f92819 [ISSUE #6693]Fix the description of the acl directory in
the document is incorrect (#6694)
add e73a9aa8a7 [ISSUE #6706] brokerPermission cannot stop messages flow
in unwritable brokers
add 41e9b8cf06 [ISSUE #6703] Fix the incorrect of confirmOffset when
recovering abnormally caused by message loss due to asynchronous flushing after
restarting
add 42c5fd5fbd [ISSUE #6708] Use GitHub cache for CodeQL
add 34b20950c5 chore(metrics): bump opentelemetry version to 1.26.0 (#6705)
add 0a329ba627 [ISSUE #6699] Make NotificationProcessor use
PopLongPollingService (#6700)
add bcf40a9119 [ISSUE #6516] Remove redundant code from ThreadLocalIndex
(#6517)
add 09ad52b9e1 [ISSUE #6712] Remove useless method
BrokerOuterAPI#pullMessageFromSpecificBroker (#6713)
add f33ac2a3ec [ISSUE #6714] Replace the deprecated method
DefaultMQPushConsumer#getDefaultMQPushConsumerImpl (#6715)
add 6b6fb17224 [ISSUE #6722] Bugfix timer thread has error when timer not
enable (#6723)
add 5dc2e20efc [ISSUE #6728] Compute the confirmOffset without considering
new connections (#6729)
add 9d411cf04a Make configPath unable to update at runtime (#6733)
add f1b411cecc Remove filter server module (#6749)
add 847d87b5f3 Prepare to release version 5.1.1 (#6753)
add e244ebb99a [maven-release-plugin] prepare release rocketmq-all-5.1.1
(#6763)
add 8aea26ef8f [maven-release-plugin] prepare for next development
iteration
add 5f747f5c24 [ISSUE #6747] Add INNER_MULTI_DISPATCH check, can not
contains path separator
add 9dfd4a9599 [ISSUE #6761] Support reentrant notification orderly for
broker (#6762)
add 92ea901d7b [ISSUE #6765] org.apache.rocketmq.util.cache doesn't look
like it's being used
add 70480a1fa9 Remove redundant variables (#6740)
add 7c24daf205 [ISSUE #6771] Merge some cases in
PullMessageProcessor#composeResponseHeader method (#6772)
add bd7db7ec62 [ISSUE #6774] Update README.md rocketmq version to 5.1.1
(#6775)
add 016b0310e0 [ISSUE #6789] Modify placeholder in DefaultMQProducerImpl
(#6790)
add 3dcba4b5cd [ISSUE #6792] Fix the bug that send method blocked on
log.warn for a long time (#6793)
add eef581b464 [ISSUE #6785] Isolate the remoteChannel by group (#6786)
add 985319ba2a [ISSUE #6797]Support batch ack when reput buffer ak to
store in PopBufferMergeService (#6798)
add 224d660670 doc: fix typo in operation.md (#6799)
add 330d56b2cf [ISSUE#6595] Fix NPE and repeat access key log (#6596)
add ea3298065c Polish the persistent_unique_broker_id document (#6817)
add e545e3b359 [ISSUE #6803] Benchmark support reportInterval option
(#6804)
add f4439c971c [ISSUE #6819] Rename brokerHeartbeatExecutorService
executorService name (#6820)
add 40ada807b3 [ISSUE #6828] return the number of assignments equal to the
number of messageQueues for order consumer (#6829)
add 529976f8fb [ISSUE #6777] Support metric in controller (#6778)
add 1a9a8b1969 [ISSUE #6624]Support mark() & reset() for
TieredFileSegmentInputStream (#6625)
add c68fb8f1b9 [ISSUE #6845] Build controller with bazel (#6846)
add fb1c67d536 Fix incorrect naming (#6843)
add acd8b099df [ISSUE #6849] Fix the issue of increasing RT in three
replicators
add 1d62b74ab6 [ISSUE #6779] Support scheduled message for LMQ (#6780)
add bee5077bcb [ISSUE #6336] [RIP-62] Cold Read Control (#6507)
add a325d144b2 [ISSUE #6858] passing through ProxyContext for future
expansion (#6859)
add 450d0d69cc [ISSUE #6154] Support Amazon S3 backend in TieredStorage
(#6495)
add f10f90550f Modify CURRENT_VERSION to 5.1.2 (#6862)
add 4d82b307ef [ISSUE #6866] Move the judgment logic of grpc TLS mode to
improve the scalability of ProtocolNegotiator (#6867)
add 6c9359fbfc [ISSUE #6824] Add golang e2e test (#6825)
add 6eac107005 [ISSUE #6633] [RIP-65] Improving Tiered Storage
Implementation (#6781)
add 0f1ff25512 [ISSUE #6881] Fix scheduled messages are replayed bug
(#6882)
add 91d8ee16a0 [ISSUE #6800] Change the config variable isEnableBatchPush
to enableBatchPush (#6801)
add 749967baa8 [maven-release-plugin] prepare release rocketmq-all-5.1.2
(#6892)
add ad4cc957fb [maven-release-plugin] prepare for next development
iteration (#6895)
add b44a1ebc36 [ISSUE apache#6576] Fix pop lmq message in client (#6577)
add 4291971c03 [ISSUE #5866] fix client-side memory leak of inactive
channel (#5867)
add aaa4a4b5fc Add attribute for SubscriptionGroupConfig (#6891)
add 3dda55e812 [RIP-64] Heartbeat Optimization (#6724)
add aea5811df0 [ISSUE #6884] Resolve proxy sending mentality to broker and
unable to find ACL configuration related (#6885)
add 2246c32537 Add attributesBuilderSupplier for BrokerMetricsManager
(#6901)
add 0b76f6f619 Fix the problem that the proxy in the cluster mode obtains
the wrong address of broker (#6909)
add 3ac885705d new feature: sql expression CONTAINS support (#6864)
add 6238caaac9 [ISSUE #6841] new feature: pop batch ack implementation
broker-side (#6842)
add 1f0cdc88f8 Temporarily ignoring testQueryMessageAsync testing on the
Linux platform (#6930)
add 4e09a9cfe9 [ISSUE #6904] Fix fail to start broker if mapped file size
is 0 (#6903)
add 82492a6208 [ISSUE #6926] Fixing the error in the initialization order
of replicasManager caused the controller mode to fail to start.
add f76e8670b0 [ISSUE #6931] Set table reference the same object for
setSubscriptionGroupTable method
add fd4a397a14 [ISSUE #6917] fix cannot query all messages of the same
msgId
add 5d6ee6384f [ISSUE #6910] Extract the interval of fetchNameServerAddr
add 9899be15e7 [ISSUE #6933] Support recreate file if local cq and tiered
storage offset not match
add 867c296150 [ISSUE #6916] support startsWith and endsWith in sql
filter. (#6915)
add 3358592232 [ISSUE #6935] Prepare to release Apache RocketMQ 5.1.3
add f7425f52f9 [maven-release-plugin] prepare release rocketmq-all-5.1.3
(#6938)
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 10 +-
.github/ISSUE_TEMPLATE/bug_report.yml | 113 +++
.github/ISSUE_TEMPLATE/config.yml | 5 +
.github/ISSUE_TEMPLATE/enhancement_request.yml | 57 ++
.github/ISSUE_TEMPLATE/feature_request.yml | 40 +
.github/ISSUE_TEMPLATE/issue_template.md | 50 --
.github/PULL_REQUEST_TEMPLATE.md | 29 +-
.github/workflows/bazel.yml | 2 +-
.github/workflows/codeql_analysis.yml | 10 +-
.github/workflows/maven.yaml | 3 +-
.github/workflows/pr-e2e-test.yml | 128 ++-
.github/workflows/push-ci.yml | 127 ++-
BUILD.bazel | 2 +
README.md | 15 +-
WORKSPACE | 16 +-
acl/pom.xml | 2 +-
.../org/apache/rocketmq/acl/AccessValidator.java | 2 +-
.../org/apache/rocketmq/acl/common/AclUtils.java | 91 +--
.../apache/rocketmq/acl/plain/PlainAccessData.java | 104 +++
.../rocketmq/acl/plain/PlainAccessResource.java | 31 +-
.../rocketmq/acl/plain/PlainAccessValidator.java | 4 +-
.../rocketmq/acl/plain/PlainPermissionChecker.java | 15 +-
.../rocketmq/acl/plain/PlainPermissionManager.java | 181 ++---
.../acl/plain/RemoteAddressStrategyFactory.java | 38 +-
.../apache/rocketmq/acl/common/AclUtilsTest.java | 43 +-
.../apache/rocketmq/acl/common/PermissionTest.java | 4 +-
.../acl/plain/PlainAccessControlFlowTest.java | 25 +-
.../acl/plain/PlainAccessValidatorTest.java | 58 +-
.../acl/plain/PlainPermissionManagerTest.java | 73 +-
.../acl/plain/RemoteAddressStrategyTest.java | 72 +-
broker/BUILD.bazel | 4 +
broker/pom.xml | 10 +-
.../apache/rocketmq/broker/BrokerController.java | 241 +++---
.../org/apache/rocketmq/broker/BrokerStartup.java | 12 +-
.../broker/client/ClientHousekeepingService.java | 4 -
.../rocketmq/broker/client/ConsumerManager.java | 19 +
.../rocketmq/broker/coldctr/ColdCtrStrategy.java | 44 +-
.../broker/coldctr/ColdDataCgCtrService.java | 250 ++++++
.../coldctr/ColdDataPullRequestHoldService.java | 105 +++
.../broker/coldctr/PIDAdaptiveColdCtrStrategy.java | 85 ++
.../broker/coldctr/SimpleColdCtrStrategy.java | 51 ++
.../broker/controller/ReplicasManager.java | 563 ++++++++++---
.../broker/dledger/DLedgerRoleChangeHandler.java | 4 +-
.../broker/filtersrv/FilterServerManager.java | 169 ----
.../broker/filtersrv/FilterServerUtil.java | 42 -
.../rocketmq/broker/longpolling/PollingHeader.java | 65 ++
.../rocketmq/broker/longpolling/PollingResult.java | 10 +-
.../broker/longpolling/PopLongPollingService.java | 333 ++++++++
.../rocketmq/broker/longpolling/PopRequest.java | 42 +-
.../broker/metrics/BrokerMetricsManager.java | 45 +-
.../broker/metrics/ConsumerLagCalculator.java | 118 ++-
.../broker/offset/ConsumerOrderInfoManager.java | 37 +-
.../apache/rocketmq/broker/out/BrokerOuterAPI.java | 216 +++--
.../broker/processor/AckMessageProcessor.java | 290 ++++---
.../broker/processor/AdminBrokerProcessor.java | 181 ++++-
.../broker/processor/ClientManageProcessor.java | 100 ++-
.../processor/DefaultPullMessageResultHandler.java | 4 +-
.../broker/processor/EndTransactionProcessor.java | 39 +
.../broker/processor/ForwardRequestProcessor.java | 45 --
.../broker/processor/NotificationProcessor.java | 153 +---
.../broker/processor/PeekMessageProcessor.java | 4 +-
.../broker/processor/PopBufferMergeService.java | 101 ++-
.../processor/PopInflightMessageCounter.java | 22 +-
.../broker/processor/PopMessageProcessor.java | 374 ++-------
.../broker/processor/PopReviveService.java | 72 +-
.../broker/processor/PullMessageProcessor.java | 61 +-
.../broker/processor/QueryMessageProcessor.java | 9 +-
.../broker/processor/SendMessageProcessor.java | 13 +-
.../broker/schedule/ScheduleMessageService.java | 87 +-
.../rocketmq/broker/slave/SlaveSynchronize.java | 83 +-
.../subscription/SubscriptionGroupManager.java | 49 +-
.../rocketmq/broker/topic/TopicConfigManager.java | 123 +--
.../broker/topic/TopicRouteInfoManager.java | 9 +-
.../queue/TransactionalMessageUtil.java | 16 +
broker/src/main/resources/rmq.broker.logback.xml | 150 +++-
.../controller/ReplicasManagerRegisterTest.java | 352 ++++++++
.../broker/controller/ReplicasManagerTest.java | 80 +-
.../broker/filter/MessageStoreWithFilterTest.java | 3 +-
.../broker/filtersrv/FilterServerManagerTest.java | 88 --
.../broker/metrics/BrokerMetricsManagerTest.java | 68 ++
...ConsumerOrderInfoManagerLockFreeNotifyTest.java | 5 +
.../offset/ConsumerOrderInfoManagerTest.java | 57 +-
.../broker/processor/AckMessageProcessorTest.java | 252 +++++-
.../broker/processor/AdminBrokerProcessorTest.java | 32 +
.../processor/ClientManageProcessorTest.java | 101 ++-
.../processor/EndTransactionProcessorTest.java | 41 +
.../processor/PopInflightMessageCounterTest.java | 13 +-
.../broker/processor/PopMessageProcessorTest.java | 16 +-
.../schedule/ScheduleMessageServiceTest.java | 2 +-
.../subscription/SubscriptionGroupManagerTest.java | 77 ++
.../broker/topic/TopicConfigManagerTest.java | 17 +-
.../queue/TransactionalMessageUtilTest.java | 40 +
client/pom.xml | 2 +-
.../org/apache/rocketmq/client/ClientConfig.java | 14 +-
.../java/org/apache/rocketmq/client/MQAdmin.java | 8 +-
.../org/apache/rocketmq/client/MqClientAdmin.java | 110 +++
.../org/apache/rocketmq/client/Validators.java | 9 +
...LocalIndex.java => NameserverAccessConfig.java} | 34 +-
.../rocketmq/client/common/ThreadLocalIndex.java | 2 +-
.../client/consumer/DefaultMQPushConsumer.java | 26 +-
.../consumer/store/RemoteBrokerOffsetStore.java | 3 +-
.../apache/rocketmq/client/impl/MQAdminImpl.java | 14 +-
.../rocketmq/client/impl/MQClientAPIImpl.java | 304 ++++---
.../client/impl/admin/MqClientAdminImpl.java | 438 ++++++++++
.../client/impl/consumer/AssignedMessageQueue.java | 4 -
.../ConsumeMessageConcurrentlyService.java | 13 +-
.../consumer/ConsumeMessageOrderlyService.java | 15 +-
.../consumer/ConsumeMessagePopOrderlyService.java | 2 +-
.../impl/consumer/DefaultLitePullConsumerImpl.java | 39 +-
.../impl/consumer/DefaultMQPushConsumerImpl.java | 5 +-
.../client/impl/consumer/ProcessQueue.java | 2 +-
.../client/impl/consumer/PullMessageService.java | 13 +-
.../client/impl/consumer/RebalancePushImpl.java | 2 +-
.../client/impl/factory/MQClientInstance.java | 193 +++--
.../mqclient/DoNothingClientRemotingProcessor.java | 2 +-
.../client/impl}/mqclient/MQClientAPIExt.java | 46 +-
.../client/impl}/mqclient/MQClientAPIFactory.java | 24 +-
.../impl/producer/DefaultMQProducerImpl.java | 53 +-
.../client/impl/producer/TopicPublishInfo.java | 2 +-
.../rocketmq/client/latency/MQFaultStrategy.java | 6 +-
.../client/producer/DefaultMQProducer.java | 4 +-
.../client/trace/AsyncTraceDispatcher.java | 11 +-
client/src/main/resources/rmq.client.logback.xml | 9 +-
.../rocketmq/client/impl/MQClientAPIImplTest.java | 77 ++
common/pom.xml | 6 +-
.../org/apache/rocketmq/common/BoundaryType.java | 34 +-
.../org/apache/rocketmq/common/BrokerConfig.java | 131 +--
.../org/apache/rocketmq/common/BrokerIdentity.java | 5 +-
.../apache/rocketmq/common/ControllerConfig.java | 118 +++
.../java/org/apache/rocketmq/common/MQVersion.java | 2 +-
.../java/org/apache/rocketmq/common/MixAll.java | 22 +
.../apache/rocketmq/common/PlainAccessConfig.java | 18 +-
.../apache/rocketmq/common/PopAckConstants.java | 5 +
.../org/apache/rocketmq/common/ServiceThread.java | 36 +-
.../common/SubscriptionGroupAttributes.java | 12 +-
.../java/org/apache/rocketmq/common/UtilAll.java | 27 +
.../rocketmq/common/attribute/AttributeUtil.java | 132 +++
.../rocketmq/common/coldctr/AccAndTimeStamp.java | 63 ++
.../common/constant/FIleReadaheadMode.java | 9 +-
.../rocketmq/common/constant/LoggerName.java | 3 +
.../rocketmq/common/message/MessageType.java | 4 +-
.../common/metrics/MetricsExporterType.java | 40 +-
.../common/utils}/AbstractStartAndShutdown.java | 2 +-
.../apache/rocketmq/common/utils/NetworkUtil.java | 2 +-
.../apache/rocketmq/common/utils}/Shutdown.java | 2 +-
.../org/apache/rocketmq/common/utils}/Start.java | 2 +-
.../rocketmq/common/utils}/StartAndShutdown.java | 2 +-
.../apache/rocketmq/common/utils/ThreadUtils.java | 32 +-
.../apache/rocketmq/common/ServiceThreadTest.java | 25 -
.../org/apache/rocketmq/common/UtilAllTest.java | 61 ++
container/pom.xml | 2 +-
.../apache/rocketmq/container/BrokerContainer.java | 25 +-
.../rocketmq/container/BrokerContainerConfig.java | 14 +-
controller/BUILD.bazel | 13 +
controller/pom.xml | 6 +-
.../controller/BrokerHeartbeatManager.java | 26 +-
.../org/apache/rocketmq/controller/Controller.java | 26 +-
.../rocketmq/controller/ControllerManager.java | 208 +++--
.../rocketmq/controller/elect/ElectPolicy.java | 9 +-
.../controller/elect/impl/DefaultElectPolicy.java | 64 +-
.../controller/helper/BrokerLifecycleListener.java | 10 +-
.../controller/helper/BrokerLiveInfoGetter.java | 11 +-
.../controller/helper/BrokerValidPredicate.java | 6 +-
.../controller/impl/DLedgerController.java | 154 +++-
.../impl/DLedgerControllerStateMachine.java | 13 +-
.../impl/event/AlterSyncStateSetEvent.java | 6 +-
.../controller/impl/event/ApplyBrokerIdEvent.java | 26 +-
.../impl/event/CleanBrokerDataEvent.java | 20 +-
.../controller/impl/event/ElectMasterEvent.java | 31 +-
.../controller/impl/event/EventSerializer.java | 2 +
.../rocketmq/controller/impl/event/EventType.java | 6 +-
...rIdEvent.java => UpdateBrokerAddressEvent.java} | 48 +-
.../impl/heartbeat/BrokerIdentityInfo.java | 51 +-
.../{ => impl/heartbeat}/BrokerLiveInfo.java | 13 +-
.../DefaultBrokerHeartbeatManager.java | 76 +-
.../controller/impl/manager/BrokerInfo.java | 76 --
.../controller/impl/manager/BrokerReplicaInfo.java | 110 +++
.../impl/manager/ReplicasInfoManager.java | 552 +++++++------
.../controller/impl/manager/SyncStateInfo.java | 50 +-
.../metrics/ControllerMetricsConstant.java | 148 ++++
.../metrics/ControllerMetricsManager.java | 383 +++++++++
.../processor/ControllerRequestProcessor.java | 267 +++++--
.../src/main/resources/rmq.controller.logback.xml | 38 +-
.../rocketmq/controller/ControllerManagerTest.java | 254 ++++++
.../controller/ControllerRequestProcessorTest.java | 70 ++
.../rocketmq/controller/ControllerTestBase.java | 12 +-
.../controller/impl/DLedgerControllerTest.java | 386 +++++++++
.../DefaultBrokerHeartbeatManagerTest.java | 7 +-
.../impl/controller/ControllerManagerTest.java | 200 -----
.../controller/impl/DLedgerControllerTest.java | 317 --------
.../impl/manager/ReplicasInfoManagerTest.java | 336 --------
.../impl/manager/ReplicasInfoManagerTest.java | 466 +++++++++++
distribution/benchmark/runclass.sh | 1 +
distribution/bin/runbroker.sh | 6 +-
distribution/bin/runserver.sh | 8 +-
distribution/bin/tools.sh | 6 +-
distribution/pom.xml | 2 +-
docs/cn/Configuration_System.md | 2 +-
docs/cn/Example_Compaction_Topic_cn.md | 22 +-
...Multiple_ACL_Files_\350\256\276\350\256\241.md" | 10 +-
docs/cn/controller/deploy.md | 26 +
docs/cn/controller/persistent_unique_broker_id.md | 135 ++++
.../fail_apply_broker_id.png | Bin 0 -> 21614 bytes
.../fail_create_metadata_file_and_delete_temp.png | Bin 0 -> 8975 bytes
.../fail_create_temp_metadata_file.png | Bin 0 -> 21695 bytes
.../persistent_unique_broker_id/normal_restart.png | Bin 0 -> 32913 bytes
.../register_process.png | Bin 0 -> 131812 bytes
.../register_state_transfer.png | Bin 0 -> 94072 bytes
docs/en/Example_Compaction_Topic.md | 26 +-
docs/en/controller/deploy.md | 27 +
docs/en/controller/persistent_unique_broker_id.md | 129 +++
.../fail_apply_broker_id.png | Bin 0 -> 21614 bytes
.../fail_create_metadata_file_and_delete_temp.png | Bin 0 -> 8975 bytes
.../fail_create_temp_metadata_file.png | Bin 0 -> 21695 bytes
.../persistent_unique_broker_id/normal_restart.png | Bin 0 -> 32913 bytes
.../register_process.png | Bin 0 -> 131812 bytes
.../register_state_transfer.png | Bin 0 -> 94072 bytes
docs/en/operation.md | 2 +-
example/pom.xml | 2 +-
.../rocketmq/example/benchmark/BatchProducer.java | 53 +-
.../rocketmq/example/benchmark/Consumer.java | 11 +-
.../rocketmq/example/benchmark/Producer.java | 41 +-
.../example/benchmark/TransactionProducer.java | 11 +-
.../rocketmq/example/simple/PullConsumer.java | 13 +-
.../rocketmq/example/simple/PushConsumer.java | 13 +-
.../tracemessage/OpenTracingPushConsumer.java | 2 +-
filter/pom.xml | 2 +-
.../filter/expression/ComparisonExpression.java | 252 ++++++
.../rocketmq/filter/parser/ParseException.java | 2 +-
.../rocketmq/filter/parser/SelectorParser.java | 885 +++++++++++----------
.../rocketmq/filter/parser/SelectorParser.jj | 37 +-
.../filter/parser/SelectorParserConstants.java | 25 +-
.../filter/parser/SelectorParserTokenManager.java | 296 +++++--
.../rocketmq/filter/parser/SimpleCharStream.java | 2 +-
.../org/apache/rocketmq/filter/parser/Token.java | 2 +-
.../rocketmq/filter/parser/TokenMgrError.java | 2 +-
.../org/apache/rocketmq/filter/ExpressionTest.java | 366 +++++++++
.../org/apache/rocketmq/filter/ParserTest.java | 4 +-
namesrv/pom.xml | 2 +-
.../namesrv/processor/DefaultRequestProcessor.java | 6 +
.../namesrv/routeinfo/RouteInfoManager.java | 65 +-
namesrv/src/main/resources/rmq.namesrv.logback.xml | 13 +-
.../namesrv/processor/RequestProcessorTest.java | 41 +-
openmessaging/pom.xml | 2 +-
.../rocketmq/consumer/PushConsumerImpl.java | 2 +-
pom.xml | 119 ++-
proxy/BUILD.bazel | 5 +-
proxy/pom.xml | 6 +-
.../org/apache/rocketmq/proxy/ProxyStartup.java | 8 +-
.../rocketmq/proxy/common/ContextVariable.java | 2 +
.../proxy/common/MessageReceiptHandle.java | 38 +-
.../apache/rocketmq/proxy/common/ProxyContext.java | 9 +
.../rocketmq/proxy/common/RenewStrategyPolicy.java | 70 ++
.../rocketmq/proxy/config/Configuration.java | 1 +
.../proxy/config/ConfigurationManager.java | 11 +
.../apache/rocketmq/proxy/config/ProxyConfig.java | 55 +-
.../org/apache/rocketmq/proxy/grpc/GrpcServer.java | 7 +-
.../rocketmq/proxy/grpc/GrpcServerBuilder.java | 67 +-
.../proxy/grpc/OptionalSSLProtocolNegotiator.java | 93 ++-
.../interceptor/AuthenticationInterceptor.java | 1 +
.../grpc/interceptor/InterceptorConstants.java | 3 +
.../proxy/grpc/v2/DefaultGrpcMessingActivity.java | 2 +-
.../proxy/grpc/v2/GrpcMessagingApplication.java | 6 +-
.../proxy/grpc/v2/GrpcMessingActivity.java | 2 +-
.../proxy/grpc/v2/channel/GrpcChannelManager.java | 5 +-
.../proxy/grpc/v2/client/ClientActivity.java | 2 +-
.../grpc/v2/common/GrpcClientSettingsManager.java | 2 +-
.../proxy/grpc/v2/common/GrpcConverter.java | 5 +
.../proxy/grpc/v2/consumer/AckMessageActivity.java | 2 +-
.../consumer/ChangeInvisibleDurationActivity.java | 2 +-
.../grpc/v2/consumer/ReceiveMessageActivity.java | 4 +-
.../v2/producer/ForwardMessageToDLQActivity.java | 2 +-
.../proxy/grpc/v2/route/RouteActivity.java | 60 +-
.../proxy/metrics/ProxyMetricsManager.java | 41 +-
.../proxy/processor/AbstractProcessor.java | 2 +-
.../proxy/processor/ConsumerProcessor.java | 32 +-
.../proxy/processor/DefaultMessagingProcessor.java | 6 +-
.../proxy/processor/MessagingProcessor.java | 2 +-
.../proxy/processor/ProducerProcessor.java | 13 +-
.../proxy/processor/ReceiptHandleProcessor.java | 29 +-
.../proxy/processor/TransactionProcessor.java | 3 +-
.../remoting/MultiProtocolRemotingServer.java | 19 +-
.../proxy/remoting/RemotingProtocolServer.java | 5 +-
.../activity/AbstractRemotingActivity.java | 19 +-
.../remoting/activity/ClientManagerActivity.java | 15 +
.../remoting/activity/ConsumerManagerActivity.java | 48 ++
.../remoting/activity/SendMessageActivity.java | 2 +-
.../proxy/remoting/channel/RemotingChannel.java | 18 +
.../remoting/channel/RemotingChannelManager.java | 2 +-
.../remoting/pipeline/AuthenticationPipeline.java | 2 -
.../http2proxy/Http2ProtocolProxyHandler.java | 4 +-
.../http2proxy/Http2ProxyBackendHandler.java | 4 +-
.../http2proxy/Http2ProxyFrontendHandler.java | 4 +-
.../protocol/remoting/RemotingProtocolHandler.java | 33 +-
.../proxy/service/ClusterServiceManager.java | 19 +-
.../proxy/service/LocalServiceManager.java | 15 +-
.../rocketmq/proxy/service/ServiceManager.java | 2 +-
.../proxy/service/admin/DefaultAdminService.java | 4 +-
.../service/client/ClusterConsumerManager.java | 9 +-
.../ProxyClientRemotingProcessor.java | 2 +-
.../service/message/ClusterMessageService.java | 22 +-
.../service/metadata/ClusterMetadataService.java | 11 +-
.../service/metadata/LocalMetadataService.java | 5 +-
.../proxy/service/metadata/MetadataService.java | 5 +-
.../service/relay/AbstractProxyRelayService.java | 1 +
.../service/route/ClusterTopicRouteService.java | 25 +-
.../service/route/LocalTopicRouteService.java | 15 +-
.../proxy/service/route/MessageQueueView.java | 4 +
.../proxy/service/route/TopicRouteService.java | 17 +-
.../sysmessage/AbstractSystemMessageSyncer.java | 15 +-
.../proxy/service/sysmessage/HeartbeatSyncer.java | 11 +-
.../transaction/AbstractTransactionService.java | 10 +-
.../transaction/ClusterTransactionService.java | 23 +-
.../transaction/LocalTransactionService.java | 9 +-
.../transaction/TransactionDataManager.java | 2 +-
.../service/transaction/TransactionService.java | 14 +-
proxy/src/main/resources/rmq.proxy.logback.xml | 82 +-
.../proxy/common/RenewStrategyPolicyTest.java | 66 ++
.../proxy/config/ConfigurationManagerTest.java | 8 +-
.../proxy/grpc/v2/client/ClientActivityTest.java | 4 +-
.../ChangeInvisibleDurationActivityTest.java | 2 +-
.../producer/ForwardMessageToDLQActivityTest.java | 2 +-
.../grpc/v2/producer/SendMessageActivityTest.java | 2 +-
.../proxy/grpc/v2/route/RouteActivityTest.java | 25 +-
.../proxy/processor/ConsumerProcessorTest.java | 15 +-
.../proxy/processor/ProducerProcessorTest.java | 4 +-
.../processor/ReceiptHandleProcessorTest.java | 91 ++-
.../proxy/processor/TransactionProcessorTest.java | 2 +-
.../activity/AbstractRemotingActivityTest.java | 26 +-
.../remoting/activity/SendMessageActivityTest.java | 2 +-
.../rocketmq/proxy/service/BaseServiceTest.java | 11 +-
.../service/admin/DefaultAdminServiceTest.java | 4 +-
.../service/message/ClusterMessageServiceTest.java | 5 +-
.../metadata/ClusterMetadataServiceTest.java | 11 +-
.../proxy/service/mqclient/MQClientAPIExtTest.java | 2 +
.../mqclient/ProxyClientRemotingProcessorTest.java | 1 +
.../route/ClusterTopicRouteServiceTest.java | 54 +-
.../service/route/LocalTopicRouteServiceTest.java | 7 +-
.../service/sysmessage/HeartbeatSyncerTest.java | 149 ++--
.../AbstractTransactionServiceTest.java | 14 +-
.../transaction/ClusterTransactionServiceTest.java | 26 +-
.../rmq-proxy-home/conf/logback_proxy.xml | 60 +-
remoting/pom.xml | 2 +-
.../apache/rocketmq/remoting/RemotingClient.java | 26 +
.../HeartbeatV2Result.java} | 42 +-
.../rocketmq/remoting/common/RemotingHelper.java | 69 +-
.../rocketmq/remoting/common/ServiceThread.java | 3 +-
.../remoting/metrics/RemotingMetricsConstant.java | 33 -
.../remoting/metrics/RemotingMetricsManager.java | 9 -
.../rocketmq/remoting/netty/FileRegionEncoder.java | 2 +-
.../rocketmq/remoting/netty/NettyDecoder.java | 3 +-
.../rocketmq/remoting/netty/NettyEncoder.java | 3 +-
.../remoting/netty/NettyRemotingAbstract.java | 9 +-
.../remoting/netty/NettyRemotingClient.java | 124 ++-
.../remoting/netty/NettyRemotingServer.java | 112 +--
.../netty/RemotingCodeDistributionHandler.java | 10 +-
.../apache/rocketmq/remoting/netty/TlsHelper.java | 4 +-
.../protocol/BitSetSerializerDeserializer.java | 52 ++
.../remoting/protocol/RemotingCommand.java | 8 +-
.../rocketmq/remoting/protocol/RequestCode.java | 8 +
.../rocketmq/remoting/protocol/ResponseCode.java | 11 +-
.../rocketmq/remoting/protocol/body/BatchAck.java | 131 +++
.../BatchAckMessageRequestBody.java} | 34 +-
.../remoting/protocol/body/BrokerReplicasInfo.java | 106 ++-
.../protocol/body/ElectMasterResponseBody.java | 86 ++
.../remoting/protocol/body/RegisterBrokerBody.java | 22 +-
.../protocol/body/RoleChangeNotifyEntry.java | 88 ++
.../remoting/protocol/body/SyncStateSet.java | 8 +-
.../remoting/protocol/filter/FilterAPI.java | 48 +-
.../remoting/protocol/header/ExtraInfoUtil.java | 13 +-
.../protocol/header/NotificationRequestHeader.java | 18 +
.../NotifyBrokerRoleChangedRequestHeader.java | 37 +-
.../protocol/header/PopMessageRequestHeader.java | 11 +
.../controller/AlterSyncStateSetRequestHeader.java | 28 +-
.../controller/ElectMasterRequestHeader.java | 57 +-
.../controller/ElectMasterResponseHeader.java | 52 +-
.../controller/GetReplicaInfoRequestHeader.java | 18 +-
.../controller/GetReplicaInfoResponseHeader.java | 26 +-
.../RegisterBrokerToControllerRequestHeader.java | 142 ----
.../CleanControllerBrokerDataRequestHeader.java | 30 +-
.../ApplyBrokerIdRequestHeader.java} | 61 +-
.../ApplyBrokerIdResponseHeader.java} | 51 +-
.../GetNextBrokerIdRequestHeader.java} | 51 +-
.../GetNextBrokerIdResponseHeader.java} | 56 +-
.../RegisterBrokerToControllerRequestHeader.java} | 58 +-
.../RegisterBrokerToControllerResponseHeader.java | 76 +-
.../RegisterMessageFilterClassRequestHeader.java | 69 --
.../remoting/protocol/heartbeat/HeartbeatData.java | 32 +
.../statictopic/TopicQueueMappingUtils.java | 27 +-
.../subscription/SimpleSubscriptionData.java | 91 +++
.../subscription/SubscriptionGroupConfig.java | 63 +-
.../rocketmq/remoting/rpc/ClientMetadata.java | 9 +-
.../rocketmq/remoting/SubRemotingServerTest.java | 2 +-
.../remoting/netty/NettyRemotingClientTest.java | 90 ++-
.../netty/RemotingCodeDistributionHandlerTest.java | 12 +-
.../remoting/protocol/body/BatchAckTest.java | 112 +++
srvutil/pom.xml | 2 +-
.../rocketmq/util/cache/ExpiredLocalCache.java | 84 --
.../org/apache/rocketmq/util/cache/LocalCache.java | 58 --
.../apache/rocketmq/util/cache/LockManager.java | 53 --
store/BUILD.bazel | 3 +-
store/pom.xml | 2 +-
.../rocketmq/store/AppendMessageCallback.java | 4 +-
.../java/org/apache/rocketmq/store/CommitLog.java | 334 +++++++-
.../org/apache/rocketmq/store/ConsumeQueue.java | 248 +++++-
.../apache/rocketmq/store/DefaultMessageStore.java | 125 ++-
.../apache/rocketmq/store/GetMessageResult.java | 10 +
.../org/apache/rocketmq/store/MappedFileQueue.java | 94 ++-
.../org/apache/rocketmq/store/MessageStore.java | 147 ++--
.../org/apache/rocketmq/store/RunningFlags.java | 20 +-
.../rocketmq/store/SelectMappedBufferResult.java | 10 +
.../org/apache/rocketmq/store/StoreCheckpoint.java | 12 +
.../apache/rocketmq/store/TransientStorePool.java | 2 +-
.../rocketmq/store/config/MessageStoreConfig.java | 107 ++-
.../rocketmq/store/dledger/DLedgerCommitLog.java | 26 +-
.../apache/rocketmq/store/ha/DefaultHAClient.java | 32 +-
.../rocketmq/store/ha/DefaultHAConnection.java | 31 +-
.../apache/rocketmq/store/ha/DefaultHAService.java | 2 +-
.../org/apache/rocketmq/store/ha/FlowMonitor.java | 2 +-
.../rocketmq/store/ha/GroupTransferService.java | 12 +-
.../org/apache/rocketmq/store/ha/HAService.java | 19 +
.../store/ha/autoswitch/AutoSwitchHAClient.java | 76 +-
.../ha/autoswitch/AutoSwitchHAConnection.java | 47 +-
.../store/ha/autoswitch/AutoSwitchHAService.java | 310 +++++---
.../store/ha/autoswitch/BrokerMetadata.java | 107 +++
.../rocketmq/store/ha/autoswitch/MetadataFile.java | 59 ++
.../store/ha/autoswitch/TempBrokerMetadata.java | 95 +++
.../org/apache/rocketmq/store/index/IndexFile.java | 13 +
.../apache/rocketmq/store/index/IndexHeader.java | 13 +
.../apache/rocketmq/store/kv/CompactionLog.java | 102 ++-
.../rocketmq/store/kv/CompactionService.java | 101 +--
.../apache/rocketmq/store/kv/CompactionStore.java | 86 +-
.../apache/rocketmq/store/kv/MessageFetcher.java | 28 +-
.../rocketmq/store/logfile/DefaultMappedFile.java | 29 +
.../store/metrics/DefaultStoreMetricsManager.java | 108 +--
.../store/plugin/AbstractPluginMessageStore.java | 12 +-
.../org/apache/rocketmq/store/pop/BatchAckMsg.java | 50 ++
.../rocketmq/store/queue/BatchConsumeQueue.java | 46 +-
.../store/queue/ConsumeQueueInterface.java | 12 +-
.../rocketmq/store/queue/ConsumeQueueStore.java | 51 +-
...ffsetAssigner.java => QueueOffsetOperator.java} | 40 +-
.../rocketmq/store/queue/SparseConsumeQueue.java | 2 +-
.../rocketmq/store/timer/TimerMessageStore.java | 531 ++++++++-----
.../apache/rocketmq/store/timer/TimerRequest.java | 16 +
.../java/org/apache/rocketmq/store/util/LibC.java | 6 +
.../apache/rocketmq/store/AppendCallbackTest.java | 3 +-
.../apache/rocketmq/store/BatchPutMessageTest.java | 3 +-
.../apache/rocketmq/store/ConsumeQueueTest.java | 5 +-
.../store/DefaultMessageStoreCleanFilesTest.java | 3 +-
.../store/DefaultMessageStoreShutDownTest.java | 3 +-
.../rocketmq/store/DefaultMessageStoreTest.java | 64 +-
.../java/org/apache/rocketmq/store/HATest.java | 3 +-
.../apache/rocketmq/store/MultiDispatchTest.java | 5 +-
.../store/dledger/DLedgerMultiPathTest.java | 3 +-
.../store/dledger/MessageStoreTestBase.java | 5 +-
.../store/ha/autoswitch/AutoSwitchHATest.java | 147 ++--
.../apache/rocketmq/store/pop/BatchAckMsgTest.java | 57 ++
.../store/queue/BatchConsumeMessageTest.java | 43 +-
.../store/queue/BatchConsumeQueueTest.java | 3 +-
.../store/queue/ConsumeQueueStoreTest.java | 27 +-
.../rocketmq/store/queue/ConsumeQueueTest.java | 5 +-
.../apache/rocketmq/store/queue/QueueTestBase.java | 8 +-
.../store/timer/TimerMessageStoreTest.java | 9 +-
style/spotbugs-suppressions.xml | 2 +-
test/BUILD.bazel | 5 +-
test/pom.xml | 6 +-
.../rocketmq/test/client/rmq/RMQPopClient.java | 34 +-
.../apache/rocketmq/test/schema/SchemaTools.java | 14 +-
.../org/apache/rocketmq/test/util/TestUtil.java | 8 +-
.../test/autoswitchrole/AutoSwitchRoleBase.java | 23 +-
.../AutoSwitchRoleIntegrationTest.java | 85 +-
.../test/client/consumer/pop/BasePopOrderly.java | 19 +-
.../test/client/consumer/pop/NotificationIT.java | 93 +++
.../test/client/consumer/pop/PopOrderlyIT.java | 38 +
.../rocketmq/test/grpc/v2/ClusterGrpcIT.java | 11 +-
.../apache/rocketmq/test/grpc/v2/GrpcBaseIT.java | 23 +
.../apache/rocketmq/test/grpc/v2/LocalGrpcIT.java | 11 +-
.../rocketmq/test/offset/OffsetResetForPopIT.java | 8 +-
.../rocketmq/test/statictopic/StaticTopicIT.java | 9 +-
.../rmq-proxy-home/conf/logback_proxy.xml | 60 +-
tieredstore/BUILD.bazel | 5 +
tieredstore/pom.xml | 2 +-
.../rocketmq/tieredstore/TieredDispatcher.java | 481 ++++++-----
.../rocketmq/tieredstore/TieredMessageFetcher.java | 179 ++---
.../rocketmq/tieredstore/TieredMessageStore.java | 175 ++--
.../rocketmq/tieredstore/common/AppendResult.java | 28 +
.../rocketmq/tieredstore/common/BoundaryType.java | 11 +-
.../{BoundaryType.java => FileSegmentType.java} | 40 +-
...questFuture.java => InFlightRequestFuture.java} | 9 +-
...ightRequestKey.java => InFlightRequestKey.java} | 15 +-
.../tieredstore/common/MessageCacheKey.java | 19 +-
.../common/SelectMappedBufferResultWrapper.java | 27 +-
.../common/TieredMessageStoreConfig.java | 74 +-
.../tieredstore/common/TieredStoreExecutor.java | 72 +-
.../container/TieredContainerManager.java | 242 ------
.../exception/TieredStoreErrorCode.java | 35 +-
.../exception/TieredStoreException.java | 7 +-
.../rocketmq/tieredstore/file/CompositeAccess.java | 154 ++++
.../CompositeFlatFile.java} | 233 +++---
.../tieredstore/file/CompositeQueueFlatFile.java | 125 +++
.../{container => file}/TieredCommitLog.java | 85 +-
.../{container => file}/TieredConsumeQueue.java | 58 +-
.../tieredstore/file/TieredFileAllocator.java | 56 ++
.../TieredFlatFile.java} | 258 +++---
.../tieredstore/file/TieredFlatFileManager.java | 277 +++++++
.../{container => file}/TieredIndexFile.java | 105 +--
.../tieredstore/metadata/FileSegmentMetadata.java | 27 +-
.../tieredstore/metadata/QueueMetadata.java | 1 +
.../metadata/TieredMetadataManager.java | 293 +++----
.../metadata/TieredMetadataSerializeWrapper.java | 61 +-
.../tieredstore/metadata/TieredMetadataStore.java | 97 ++-
.../tieredstore/metadata/TopicMetadata.java | 24 +-
.../metrics/TieredStoreMetricsManager.java | 51 +-
.../tieredstore/provider/FileSegmentAllocator.java | 102 +++
.../tieredstore/provider/TieredFileSegment.java | 276 ++-----
.../tieredstore/provider/TieredStoreProvider.java | 5 +-
.../inputstream/TieredCommitLogInputStream.java | 180 +++++
.../inputstream/TieredFileSegmentInputStream.java | 182 +++++
.../TieredFileSegmentInputStreamFactory.java | 44 +
.../provider/posix/PosixFileSegment.java | 68 +-
.../tieredstore/util/MessageBufferUtil.java | 4 +-
.../rocketmq/tieredstore/util/TieredStoreUtil.java | 25 +-
.../rocketmq/tieredstore/TieredDispatcherTest.java | 130 +--
.../tieredstore/TieredMessageFetcherTest.java | 157 ++--
.../tieredstore/TieredMessageStoreTest.java | 64 +-
.../rocketmq/tieredstore/TieredStoreTestUtil.java | 68 ++
.../rocketmq/tieredstore/common/CommonTest.java | 56 --
.../common/InFlightRequestFutureTest.java | 145 ++++
.../tieredstore/container/TieredFileQueueTest.java | 235 ------
.../container/TieredMessageQueueContainerTest.java | 195 -----
.../file/CompositeQueueFlatFileTest.java | 197 +++++
.../TieredFlatFileManagerTest.java} | 64 +-
.../tieredstore/file/TieredFlatFileTest.java | 302 +++++++
.../{container => file}/TieredIndexFileTest.java | 38 +-
...oreTest.java => TieredMetadataManagerTest.java} | 180 +++--
.../metrics/TieredStoreMetricsManagerTest.java | 12 +-
.../provider/MockTieredFileSegmentInputStream.java | 38 +-
.../provider/TieredFileSegmentInputStreamTest.java | 282 +++++++
.../provider/TieredFileSegmentTest.java | 41 +-
.../memory}/MemoryFileSegment.java | 33 +-
.../memory/MemoryFileSegmentWithoutCheck.java} | 72 +-
.../provider/posix/PosixFileSegmentTest.java | 24 +-
.../tieredstore/util/MessageBufferUtilTest.java | 64 +-
tools/pom.xml | 2 +-
.../rocketmq/tools/admin/DefaultMQAdminExt.java | 40 +-
.../tools/admin/DefaultMQAdminExtImpl.java | 39 +-
.../apache/rocketmq/tools/admin/MQAdminExt.java | 22 +-
.../rocketmq/tools/command/MQAdminStartup.java | 13 +-
.../command/acl/DeleteAccessConfigSubCommand.java | 4 +-
...d.java => CommitLogSetReadAheadSubCommand.java} | 97 +--
.../command/broker/GetBrokerConfigCommand.java | 2 +-
....java => GetColdDataFlowCtrInfoSubCommand.java} | 95 +--
...emoveColdDataFlowCtrGroupConfigSubCommand.java} | 67 +-
...pdateColdDataFlowCtrGroupConfigSubCommand.java} | 77 +-
.../consumer/GetConsumerConfigSubCommand.java | 2 +-
.../command/consumer/UpdateSubGroupSubCommand.java | 12 +
...va => CleanControllerBrokerMetaSubCommand.java} | 31 +-
.../controller/ReElectMasterSubCommand.java | 16 +-
.../command/ha/GetSyncStateSetSubCommand.java | 16 +-
.../command/message/DumpCompactionLogCommand.java | 16 +-
.../command/message/QueryMsgByKeySubCommand.java | 31 +-
.../message/QueryMsgTraceByIdSubCommand.java | 34 +-
tools/src/main/resources/rmq.tools.logback.xml | 8 +-
563 files changed, 21794 insertions(+), 10236 deletions(-)
create mode 100644 .github/ISSUE_TEMPLATE/bug_report.yml
create mode 100644 .github/ISSUE_TEMPLATE/config.yml
create mode 100644 .github/ISSUE_TEMPLATE/enhancement_request.yml
create mode 100644 .github/ISSUE_TEMPLATE/feature_request.yml
delete mode 100644 .github/ISSUE_TEMPLATE/issue_template.md
create mode 100644
acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessData.java
copy
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/BoundaryType.java
=>
broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdCtrStrategy.java
(53%)
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataPullRequestHoldService.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/coldctr/PIDAdaptiveColdCtrStrategy.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/coldctr/SimpleColdCtrStrategy.java
delete mode 100644
broker/src/main/java/org/apache/rocketmq/broker/filtersrv/FilterServerManager.java
delete mode 100644
broker/src/main/java/org/apache/rocketmq/broker/filtersrv/FilterServerUtil.java
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PollingHeader.java
copy
srvutil/src/main/java/org/apache/rocketmq/util/cache/CacheEvictHandler.java =>
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PollingResult.java
(84%)
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopLongPollingService.java
delete mode 100644
broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/controller/ReplicasManagerRegisterTest.java
delete mode 100644
broker/src/test/java/org/apache/rocketmq/broker/filtersrv/FilterServerManagerTest.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/metrics/BrokerMetricsManagerTest.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManagerTest.java
create mode 100644
client/src/main/java/org/apache/rocketmq/client/MqClientAdmin.java
copy
client/src/main/java/org/apache/rocketmq/client/common/{ThreadLocalIndex.java
=> NameserverAccessConfig.java} (56%)
create mode 100644
client/src/main/java/org/apache/rocketmq/client/impl/admin/MqClientAdminImpl.java
copy {proxy/src/main/java/org/apache/rocketmq/proxy/service =>
client/src/main/java/org/apache/rocketmq/client/impl}/mqclient/DoNothingClientRemotingProcessor.java
(96%)
rename {proxy/src/main/java/org/apache/rocketmq/proxy/service =>
client/src/main/java/org/apache/rocketmq/client/impl}/mqclient/MQClientAPIExt.java
(94%)
rename {proxy/src/main/java/org/apache/rocketmq/proxy/service =>
client/src/main/java/org/apache/rocketmq/client/impl}/mqclient/MQClientAPIFactory.java
(79%)
rename srvutil/src/main/java/org/apache/rocketmq/util/cache/CacheObject.java
=> common/src/main/java/org/apache/rocketmq/common/BoundaryType.java (60%)
copy
srvutil/src/main/java/org/apache/rocketmq/util/cache/CacheEvictHandler.java =>
common/src/main/java/org/apache/rocketmq/common/SubscriptionGroupAttributes.java
(75%)
create mode 100644
common/src/main/java/org/apache/rocketmq/common/attribute/AttributeUtil.java
create mode 100644
common/src/main/java/org/apache/rocketmq/common/coldctr/AccAndTimeStamp.java
copy proxy/src/main/java/org/apache/rocketmq/proxy/common/Start.java =>
common/src/main/java/org/apache/rocketmq/common/constant/FIleReadaheadMode.java
(84%)
rename
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/filtersrv/RegisterFilterServerRequestHeader.java
=>
common/src/main/java/org/apache/rocketmq/common/metrics/MetricsExporterType.java
(56%)
rename {proxy/src/main/java/org/apache/rocketmq/proxy/common =>
common/src/main/java/org/apache/rocketmq/common/utils}/AbstractStartAndShutdown.java
(98%)
copy {proxy/src/main/java/org/apache/rocketmq/proxy/common =>
common/src/main/java/org/apache/rocketmq/common/utils}/Shutdown.java (95%)
rename {proxy/src/main/java/org/apache/rocketmq/proxy/common =>
common/src/main/java/org/apache/rocketmq/common/utils}/Start.java (95%)
rename {proxy/src/main/java/org/apache/rocketmq/proxy/common =>
common/src/main/java/org/apache/rocketmq/common/utils}/StartAndShutdown.java
(95%)
copy
srvutil/src/main/java/org/apache/rocketmq/util/cache/CacheEvictHandler.java =>
controller/src/main/java/org/apache/rocketmq/controller/helper/BrokerLifecycleListener.java
(76%)
copy
srvutil/src/main/java/org/apache/rocketmq/util/cache/CacheEvictHandler.java =>
controller/src/main/java/org/apache/rocketmq/controller/helper/BrokerLiveInfoGetter.java
(77%)
rename proxy/src/main/java/org/apache/rocketmq/proxy/common/Shutdown.java =>
controller/src/main/java/org/apache/rocketmq/controller/helper/BrokerValidPredicate.java
(83%)
copy
controller/src/main/java/org/apache/rocketmq/controller/impl/event/{ApplyBrokerIdEvent.java
=> UpdateBrokerAddressEvent.java} (59%)
rename common/src/main/java/org/apache/rocketmq/common/BrokerAddrInfo.java =>
controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/BrokerIdentityInfo.java
(57%)
rename controller/src/main/java/org/apache/rocketmq/controller/{ =>
impl/heartbeat}/BrokerLiveInfo.java (93%)
rename controller/src/main/java/org/apache/rocketmq/controller/impl/{ =>
heartbeat}/DefaultBrokerHeartbeatManager.java (68%)
delete mode 100644
controller/src/main/java/org/apache/rocketmq/controller/impl/manager/BrokerInfo.java
create mode 100644
controller/src/main/java/org/apache/rocketmq/controller/impl/manager/BrokerReplicaInfo.java
create mode 100644
controller/src/main/java/org/apache/rocketmq/controller/metrics/ControllerMetricsConstant.java
create mode 100644
controller/src/main/java/org/apache/rocketmq/controller/metrics/ControllerMetricsManager.java
create mode 100644
controller/src/test/java/org/apache/rocketmq/controller/ControllerManagerTest.java
create mode 100644
controller/src/test/java/org/apache/rocketmq/controller/ControllerRequestProcessorTest.java
rename
srvutil/src/main/java/org/apache/rocketmq/util/cache/CacheEvictHandler.java =>
controller/src/test/java/org/apache/rocketmq/controller/ControllerTestBase.java
(71%)
create mode 100644
controller/src/test/java/org/apache/rocketmq/controller/impl/DLedgerControllerTest.java
rename
controller/src/test/java/org/apache/rocketmq/controller/impl/{controller/impl
=> }/DefaultBrokerHeartbeatManagerTest.java (87%)
delete mode 100644
controller/src/test/java/org/apache/rocketmq/controller/impl/controller/ControllerManagerTest.java
delete mode 100644
controller/src/test/java/org/apache/rocketmq/controller/impl/controller/impl/DLedgerControllerTest.java
delete mode 100644
controller/src/test/java/org/apache/rocketmq/controller/impl/controller/impl/manager/ReplicasInfoManagerTest.java
create mode 100644
controller/src/test/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManagerTest.java
create mode 100644 docs/cn/controller/persistent_unique_broker_id.md
create mode 100644
docs/cn/image/controller/persistent_unique_broker_id/fail_apply_broker_id.png
create mode 100644
docs/cn/image/controller/persistent_unique_broker_id/fail_create_metadata_file_and_delete_temp.png
create mode 100644
docs/cn/image/controller/persistent_unique_broker_id/fail_create_temp_metadata_file.png
create mode 100644
docs/cn/image/controller/persistent_unique_broker_id/normal_restart.png
create mode 100644
docs/cn/image/controller/persistent_unique_broker_id/register_process.png
create mode 100644
docs/cn/image/controller/persistent_unique_broker_id/register_state_transfer.png
create mode 100644 docs/en/controller/persistent_unique_broker_id.md
create mode 100644
docs/en/image/controller/persistent_unique_broker_id/fail_apply_broker_id.png
create mode 100644
docs/en/image/controller/persistent_unique_broker_id/fail_create_metadata_file_and_delete_temp.png
create mode 100644
docs/en/image/controller/persistent_unique_broker_id/fail_create_temp_metadata_file.png
create mode 100644
docs/en/image/controller/persistent_unique_broker_id/normal_restart.png
create mode 100644
docs/en/image/controller/persistent_unique_broker_id/register_process.png
create mode 100644
docs/en/image/controller/persistent_unique_broker_id/register_state_transfer.png
create mode 100644
proxy/src/main/java/org/apache/rocketmq/proxy/common/RenewStrategyPolicy.java
rename proxy/src/main/java/org/apache/rocketmq/proxy/service/{mqclient =>
client}/ProxyClientRemotingProcessor.java (98%)
create mode 100644
proxy/src/test/java/org/apache/rocketmq/proxy/common/RenewStrategyPolicyTest.java
copy
remoting/src/main/java/org/apache/rocketmq/remoting/{protocol/header/filtersrv/RegisterFilterServerResponseHeader.java
=> common/HeartbeatV2Result.java} (50%)
create mode 100644
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/BitSetSerializerDeserializer.java
create mode 100644
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BatchAck.java
rename
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/{header/filtersrv/RegisterFilterServerResponseHeader.java
=> body/BatchAckMessageRequestBody.java} (62%)
create mode 100644
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ElectMasterResponseBody.java
create mode 100644
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/RoleChangeNotifyEntry.java
delete mode 100644
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/RegisterBrokerToControllerRequestHeader.java
rename
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/{
=> admin}/CleanControllerBrokerDataRequestHeader.java (73%)
copy
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/{ElectMasterRequestHeader.java
=> register/ApplyBrokerIdRequestHeader.java} (61%)
copy
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/{GetReplicaInfoRequestHeader.java
=> register/ApplyBrokerIdResponseHeader.java} (63%)
copy
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/{GetReplicaInfoRequestHeader.java
=> register/GetNextBrokerIdRequestHeader.java} (62%)
copy
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/{ElectMasterRequestHeader.java
=> register/GetNextBrokerIdResponseHeader.java} (62%)
copy
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/{ElectMasterRequestHeader.java
=> register/RegisterBrokerToControllerRequestHeader.java} (70%)
rename
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/{
=> register}/RegisterBrokerToControllerResponseHeader.java (58%)
delete mode 100644
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/filtersrv/RegisterMessageFilterClassRequestHeader.java
create mode 100644
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SimpleSubscriptionData.java
create mode 100644
remoting/src/test/java/org/apache/rocketmq/remoting/protocol/body/BatchAckTest.java
delete mode 100644
srvutil/src/main/java/org/apache/rocketmq/util/cache/ExpiredLocalCache.java
delete mode 100644
srvutil/src/main/java/org/apache/rocketmq/util/cache/LocalCache.java
delete mode 100644
srvutil/src/main/java/org/apache/rocketmq/util/cache/LockManager.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/BrokerMetadata.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/MetadataFile.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/TempBrokerMetadata.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/pop/BatchAckMsg.java
rename
store/src/main/java/org/apache/rocketmq/store/queue/{QueueOffsetAssigner.java
=> QueueOffsetOperator.java} (69%)
create mode 100644
store/src/test/java/org/apache/rocketmq/store/pop/BatchAckMsgTest.java
create mode 100644
test/src/test/java/org/apache/rocketmq/test/client/consumer/pop/NotificationIT.java
copy
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/{BoundaryType.java
=> FileSegmentType.java} (61%)
rename
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/{InflightRequestFuture.java
=> InFlightRequestFuture.java} (89%)
rename
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/{InflightRequestKey.java
=> InFlightRequestKey.java} (84%)
delete mode 100644
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/container/TieredContainerManager.java
create mode 100644
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/CompositeAccess.java
rename
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/{container/TieredMessageQueueContainer.java
=> file/CompositeFlatFile.java} (65%)
create mode 100644
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/CompositeQueueFlatFile.java
rename tieredstore/src/main/java/org/apache/rocketmq/tieredstore/{container =>
file}/TieredCommitLog.java (51%)
rename tieredstore/src/main/java/org/apache/rocketmq/tieredstore/{container =>
file}/TieredConsumeQueue.java (62%)
create mode 100644
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/TieredFileAllocator.java
rename
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/{container/TieredFileQueue.java
=> file/TieredFlatFile.java} (63%)
create mode 100644
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/TieredFlatFileManager.java
rename tieredstore/src/main/java/org/apache/rocketmq/tieredstore/{container =>
file}/TieredIndexFile.java (83%)
create mode 100644
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/FileSegmentAllocator.java
create mode 100644
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/inputstream/TieredCommitLogInputStream.java
create mode 100644
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/inputstream/TieredFileSegmentInputStream.java
create mode 100644
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/inputstream/TieredFileSegmentInputStreamFactory.java
create mode 100644
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/TieredStoreTestUtil.java
delete mode 100644
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/common/CommonTest.java
create mode 100644
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/common/InFlightRequestFutureTest.java
delete mode 100644
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/container/TieredFileQueueTest.java
delete mode 100644
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/container/TieredMessageQueueContainerTest.java
create mode 100644
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/file/CompositeQueueFlatFileTest.java
rename
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/{container/TieredContainerManagerTest.java
=> file/TieredFlatFileManagerTest.java} (53%)
create mode 100644
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/file/TieredFlatFileTest.java
rename tieredstore/src/test/java/org/apache/rocketmq/tieredstore/{container =>
file}/TieredIndexFileTest.java (84%)
rename
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/metadata/{MetadataStoreTest.java
=> TieredMetadataManagerTest.java} (52%)
rename
proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/DoNothingClientRemotingProcessor.java
=>
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/provider/MockTieredFileSegmentInputStream.java
(50%)
create mode 100644
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/provider/TieredFileSegmentInputStreamTest.java
copy tieredstore/src/test/java/org/apache/rocketmq/tieredstore/{mock =>
provider/memory}/MemoryFileSegment.java (77%)
rename
tieredstore/src/test/java/org/apache/rocketmq/tieredstore/{mock/MemoryFileSegment.java
=> provider/memory/MemoryFileSegmentWithoutCheck.java} (53%)
copy
tools/src/main/java/org/apache/rocketmq/tools/command/broker/{GetBrokerConfigCommand.java
=> CommitLogSetReadAheadSubCommand.java} (54%)
copy
tools/src/main/java/org/apache/rocketmq/tools/command/broker/{GetBrokerConfigCommand.java
=> GetColdDataFlowCtrInfoSubCommand.java} (60%)
copy
tools/src/main/java/org/apache/rocketmq/tools/command/{acl/DeleteAccessConfigSubCommand.java
=> broker/RemoveColdDataFlowCtrGroupConfigSubCommand.java} (57%)
copy
tools/src/main/java/org/apache/rocketmq/tools/command/{acl/DeleteAccessConfigSubCommand.java
=> broker/UpdateColdDataFlowCtrGroupConfigSubCommand.java} (57%)
rename
tools/src/main/java/org/apache/rocketmq/tools/command/controller/{CleanControllerBrokerDataSubCommand.java
=> CleanControllerBrokerMetaSubCommand.java} (68%)
