* 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>
* Make AutoSwitchRoleIntegrationTest more stable
* Pass the checkstyle
* Pass the checkstyle
* Fix compatibility issues
* Simple optimization
* Remove useless import
* Pass the check style
* Pass the check style
* Modify DEFAULT_FILE_SIZE
* Modify DEFAULT_FILE_SIZE
* test
* Remove useless import
* Add more output to debug
* Use the new directory every time when start a broker
* Use the new directory every time when start a broker
* Remove console output
* Remove console output
* Remove ClientLogger
* WIP
* WIP
* Rename logger to log
* Make it compile
* WIP
* Fix bazel to use shaded slf4j
* Fix DeleteExpiredCommitLogSubCommandTest
* Fix pom.xml duplication
* Fix maven deps
* Add test logback configuration file
* Fix unit test output
* Fix logback configuration file
* All logging are made on top of slf4j
* Fix test log configuration file name
* Fix test log configuration file name for test module
* All logging are shaded slf4j targeted
* DLedger has an explicit dependency on slf4j
* Fix DLedger
* Fix DLeader issue
* Move logback configuration files to each module
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
* invert dependency between remoting and common module
* fix bazel
* Fix Bazel warning of indirect dependency
* remove duplicate class ServiceThread
* fix conflict
* revert delete class ServiceThread because of introduced by dledger
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
* [RIP-48] Support reset offset in server-side for pop message
* [RIP-48] Support reset offset in server-side for pop message
* no need remove error log
Co-authored-by: 斜阳 <terrance.lzm@alibaba-inc.com>
* support escaping transactional messages
* add integration test
* increase the number of messages and size integration test
* reorder condition and remove sysout
* add mock in unit test
* fix checkstyle
* ignore integration test by default
* use PutMessageResult.isOk() to check the result of escaping messages
* [RIP-48] Support reset offset in server side to improve the success rate
* [RIP-48] Support reset offset in server side to improve the success rate
* [RIP-48] Fix code style
* fix unit test
* no need put offset in reset command header
Co-authored-by: 斜阳 <terrance.lzm@alibaba-inc.com>
* Fix netty warning; Fix flaky integration test NormalMessageSendAndRecvIT; Fix naming typo
* Change log level
* Use awaitability to make everyone happy
* Do not submit tasks when executor has been shut down
* Rule out tests that are flaky. Aka they failed to pass 64 sequential and concurrent runs
* Change default log root directory for tests
* Follow test encyclopedia
* Fix test cases, allowing OS pick up available port to listen to
* Add sha256
* Use pull_request
* Support build with Bazel (#4865)
* Support build with Bazel, fixing tests to make them capable of running in concurrency and hermetic.
* Make test cases capable of running in parallel. (#4874)
* remove innerProducer and innerConsumer in Escape
#4832
* format code to pass code-style check
* Move topic route management logic to TopicRouteInfoManager
* Use ThreadPoolExecutor instead of creating a new ForkJoinPool
* remove retry logic
* remove unnecessary name server list
* remove unnecessary invokeId
* remove AssignmentManager and make maintenance of topic subscribe data lazy-initialized
* simply code
* remove unnecessary code
Zhanhui Li