* 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>
* 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
* 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
* [RIP-57] Add asynchronous interfaces to MessageStore
* fix unit test
* Modified according to review comments
* Remove unnecessary stubbing
* Add some other methods to MessageStore
* fix bazel test
* Skip failing test case
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
* Introduce tag estimation for lag calculation
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
* fixed according to review comments
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
yuz10