* BugFix: fix binary search consume offset by time
* polish codes.
* modify the test case: when timestamp is skewing, only find lower bound.
* modify the test case: when timestamp is skewing, only find lower bound.
* modify the test case: when timestamp is skewing, only find lower bound.
---------
Co-authored-by: Li Zhanhui <shutian.lzh@alibaba-inc.com>
* If you specify a custom first check time CheckImmunityTimeInSeconds,And the commit/rollback request whose validity period exceeds CheckImmunityTimeInSeconds and is not checked back will be processed and failed
* remove useless code
* update transactionCheckInterval default to be 30s
* refactor: simplify getPID (#5962)
* [ISSUE #5923] Add example tiered storage backend service provider (#5926)
* implement example file segment
* add metrics
* add readme
* fix license
* fix tests
* fix links in README.md
* add comment to PosixFileSegment and mark as experimental
* fix test
* optimize image quality
* Remove the useless exception class: MQRedirectException #5963
* [ISSUE #5965] Fix lmqTopicQueueTable initialization (#5968)
* [ISSUE #5965] Fix lmqTopicQueueTable initialization
* [ISSUE #5965] Fix lmqTopicQueueTable initialization
* [ISSUE #5890] Fix dledger logging (#5959)
* Fix dledger logging
* Add bridge into store module
* [ISSUE #5860] Set the value of order when create or update topic (#5861)
* [ISSUE #5939]Adjust the MQClientInstance#sendHeartbeatToAllBroker catch code block log print level from info to warn (#5940)
* [ISSUE #5924] Optimize UtilAll#sleep method (#5925)
* [ISSUE #5924]Optimize UtilAll#sleep method
* polish code
* [ISSUE #5986] optimize the BrokerOuterAPITest class code
Co-authored-by: zhouyunpeng <2474138779@qq.com>
* [ISSUE #5971] Make the internal logs related to the dledger in the controller print to a file separately (#5972)
* Make the internal logs related to the dledger in the controller print to a file separately
* Make the internal logs related to the dledger in the controller print to a file separately
* [ISSUE #5969] Remvoe duplicate deleteUnusedStats in admin processor (#5973)
* [ISSUE #5847] Add checkBlock for hasMsgFromQueue
* [ISSUE #5983] Make consumer support flow control code better (#5984)
* When encountering the flow control code, pull it after 20ms instead of 3s
* When encountering the flow control code, pull it after 20ms instead of 3s
* [ISSUE #5896] feat:add pop consumer example (#5991)
* feat:add pop consumer
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* Update example/src/main/java/org/apache/rocketmq/example/simple/PushConsumer.java
Co-authored-by: Oliver <wqdyxnbd@163.com>
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
* feat:fix
---------
Co-authored-by: mahaitao617 <mahaitao617@mahaitao617deMacBook-Pro.local>
Co-authored-by: Oliver <wqdyxnbd@163.com>
* [ISSUE #5942] Fix the produce count include the quantity of the system topic(#5943)
* [ISSUE #5999] Fix the TopicQueueMappingUtils comments typo (#6000)
* [ISSUE #5996] Optimize the RemotingSerializable class code (#5998)
* simplified RemotingSerializable null check
* optimize the RemotingSerializable class code
* [ISSUE #5994] [RIP-46] add pop and timer metrics (#5995)
* add pop and timer metrics
* fix according to review comment
* test(broker): add ReplicasManagerRegisterTest to test the register process
1. add ReplicasManagerRegisterTest to test the register process
* chore(pom): modify pom.xml to replace mockito with powermock
1. modify pom.xml to replace mockito with powermock
* build(bazel): export powermock in bazel
1. export powermock in bazel
---------
Co-authored-by: Xinda <xdshent@gmail.com>
Co-authored-by: SSpirits <admin@lv5.moe>
Co-authored-by: loboxu <loboxu@tencent.com>
Co-authored-by: pingww <pingw002@gmail.com>
Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
Co-authored-by: Slideee <yechun@corp.netease.com>
Co-authored-by: mxsm <ljbmxsm@gmail.com>
Co-authored-by: hardyfish <85128645+hardyfish@users.noreply.github.com>
Co-authored-by: zhouyunpeng <2474138779@qq.com>
Co-authored-by: rongtong <jinrongtong5@163.com>
Co-authored-by: zhiliatom <87265072+zhiliatom@users.noreply.github.com>
Co-authored-by: zhouxiang <zhouxiang.zzx@alibaba-inc.com>
Co-authored-by: mahaitao <15828010639@163.com>
Co-authored-by: mahaitao617 <mahaitao617@mahaitao617deMacBook-Pro.local>
Co-authored-by: Oliver <wqdyxnbd@163.com>
* refactor(controller): refactor the register logic
1. refactor the register logic
* refactor(controller): remove unused field in ElectMasterEvent
1. remove unused field in ElectMasterEvent
* feat(controller): add a tryElectMaster request and process logic about it
1. add a tryElectMaster request and process logic about it
* feat(controller): refactor ReplicasInfoManagerTest
1. refactor ReplicasInfoManagerTest
* refactor(controller): refactor DLedgerControllerTest
1. refactor DLedgerControllerTest
* refactor(controller): refactor ControllerManagerTest
1. refactor ControllerManagerTest
* refactor(controller): refactor ReplicasInfoManagerTest
1. refactor ReplicasInfoManagerTest
* refactor(controller): refactor register process and pass the junit test
1. refactor ReplicasInfoManagerTest
* style(broker): rename a constant
1. rename a constant
* feat(controller): update the DLedger dependency from v0.27 to v0.30
1. update the DLedger dependency from v0.27 to v0.30
* style(controller): add a white-line just for trigger GitHub action again
1. add a white-line just for trigger GitHub action again
* feat(controller): combine electMaster api and brokerTryElectMaster api
1. combine electMaster api and brokerTryElectMaster api
* feat(controller): add a logic about verifying the broker id returned from registering
1. add a logic about verifying the broker id returned from registering
* fix(controller): remove unused code and add a warning log in ControllerManager
1. remove unused code and add a warning log in ControllerManager
* fix: resolve conflicts
1. resolve conflicts
* fix(controller): remove unused class
1. remove unused class
* fix(controller): Resolve conflicts after merging
1. Resolve conflicts after merging
* refactor(controller): Refactor ReplicasInfoManager#elect
1. Refactor ReplicasInfoManager#elect
* style(controller): remove unused imports
1. remove unused imports
* style(controller): remove unused imports
1. remove unused imports
* fix(controller): resolve conflicts after merging develop branch
1. resolve conflicts after merging develop branch
* rerun
* fix(controller): resolve conflicts in ReplicasInfoManagerTest#testRegisterNewBroker after merging develop branch
1. resolve conflicts in ReplicasInfoManagerTest#testRegisterNewBroker after merging develop branch
* style(controller): pass style check
1. pass style check
* Fix retryTopicPerm in ConsumerLagCalculator
* [ISSUE #6206] Use static subscription to calculate consumer lag and latency
* Add version for SimpleSubscriptionData
* Fix hashcode and equals for SubscriptionGroupConfig
* remove brokerId in equal and hashcode method
* Add getter setter for version
* fix consumerGroupInfo and getSubscriptionDataSet npe
* Fix the issue that the endoffset of entry obtained by getBrokerEpoch is incorrect
* Fix the issue that the endoffset of entry obtained by getBrokerEpoch is incorrect
* Fix the issue that broker send heartbeat to controller frequently causing thread blocking when the network partition
* Fix the ReplicasManagerTest can not pass
* Reslove conflict with #5922
* Fix code style
* Rename isAddressCanConnect to isAddressReachable
* Rename isAddressCanConnect to isAddressReachable
* Fix availableNamesrvAddrMap can not remove old nameserver address
* Fix availableNamesrvAddrMap can not remove old nameserver address
* Pass the code style
* Support broker priority election for controller mode
* fix comment of brokerElectionPriority
* Set "The lower the value of brokerElectionPriority, the higher the priority of the broker being selected as the master."
