* 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>
* [ISSUE #6414] polish MQClientAPIImpl.getDefaultTopicRouteInfoFromNameServer parameters
* Fix to make Bazel CI pass
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
* Fix typo
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
---------
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
* 1、Graceful shutdown needs to wait for the compactionTopic to build the index
2、Exception handling that may occur when adding pullMessageFromMaster
3、Update usage docs
* fix doc
---------
Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
* feat(controller): concurrent protect ReplicasInfoManager#replicaInfoTable and ReplicasInfoManager#syncStateSetInfoTable
1. concurrent protect ReplicasInfoManager#replicaInfoTable and
ReplicasInfoManager#syncStateSetInfoTable
* docs(controller): make statemachine thread-safe and support timed checking inactive master in each broker-set
1. make statemachine thread-safe
2. support timed checking inactive
master in each broker-set
* fix(controller): Add some logic when visit the BrokerReplicaInfo to avoid NPE
1. Add some logic when visit the BrokerReplicaInfo to avoid NPE
* test(controller): polish some test logic
1. polish some test logic
* fix(controller): Revise back the ControllerConfig#controllerStorePath to avoid the Incompatibility problems
1. Revise back the ControllerConfig#controllerStorePath to avoid the
Incompatibility problems
* 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
* docs(controller): add chinese docs about persistent-unique-broker-id
1. add chinese docs about persistent-unique-broker-id
* docs(controller): optimize style in docs: persistent-unique-broker-id.md
1. optimize style in docs: persistent-unique-broker-id.md
* docs(controller): remove test in docs: persistent-unique-broker-id.md
1. remove test in docs: persistent-unique-broker-id.md
* fix rocketmq-proxy does not work properly in k8s nodePort mode
* Add configuration to support k8s nodePort mode
* rename forceUseEndpointPort to useEndpointPortFromRequest
---------
Co-authored-by: Misaki <Wsywsy22@2914883754@qq.com>
mxsm