Commit Graph
279 Commits
Author SHA1 Message Date
SSpiritsandLi Zhanhui d3de48c806 [ISSUE #5605]Introduce tag estimation for lag calculation (#5606)
* 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>
2022-11-30 14:52:59 +08:00
zhangjidi2016andzhangjidi 48b7ece986 [ISSUE #4487] The trackType is wrong when the consumer in broadcasting subscription (#5609)
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
2022-11-29 14:08:18 +08:00
zhangjidi2016andzhangjidi fdd77d1a0b [ISSUE #5562]Reset consumeOffset execution logic In a catch block,and is not executed under normal circumstances (#5563)
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
2022-11-24 09:56:58 +08:00
Aaron Ai 4469fb51dd Update group id of rocketmq logging (#5564) 2022-11-22 11:31:21 +08:00
Aaron Ai a68078fef8 [ISSUE #5484] Replace logging module with the shaded logback (#5540)
* Replace logging module with the shaded logback

* Add license header

* Fix bazel compile issue
2022-11-21 16:30:15 +08:00
rongtong d781271654 Move the header of the controller to the upper layer (#5550) 2022-11-20 21:51:32 +08:00
yukon 506b563f55 Revert "[ISSUE #5484] Replace Logging Module with Shaded Logback (#5524)" (#5537)
This reverts commit 809ff6b3e0.
2022-11-17 20:04:17 +08:00
陈永明andchangfeng b2de9e1cdf fix: DefaultMQAdminExt setting socksProxy has no effect (#5533)
Co-authored-by: changfeng <yongming.cym@alibaba-inc.com>
2022-11-17 00:39:57 +08:00
Aaron AiandLi Zhanhui 809ff6b3e0 [ISSUE #5484] Replace Logging Module with Shaded Logback (#5524)
* 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>
2022-11-17 00:38:28 +08:00
Humkum 48fab975e4 Fix : the topic attribute will be replace by null (#5527) 2022-11-16 20:28:29 +08:00
SSpiritsandLi Zhanhui ec5d3236f6 invert dependency between remoting and common module (#5503)
* 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>
2022-11-11 13:34:31 +08:00
lizhiminsand斜阳 2113c16ebc [RIP-48] Support reset offset in server-side for pop message (#5457)
* [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>
2022-11-07 13:55:03 +08:00
mxsm 520721d527 [ISSUE #5426] Fix mqadmin updateTopic CLI result print format problem (#5427) 2022-10-31 10:34:17 +08:00
a7c1d49454 [ISSUE #5356] [RIP 48] Introduces the concept of ready and inflight messages (#5357)
* Introduces the concept of ready and inflight messages

* update consumer progress subcommand

* fix consumer pull offset is less than consumer offset

* remove unused import

Co-authored-by: 斜阳 <terrance.lzm@alibaba-inc.com>
Co-authored-by: ShadowySpirits <admin@lv5.moe>
2022-10-26 15:41:41 +08:00
ltamber e38da5590f [ISSUE #3799]main compaction process (#5351)
* add compaction delete policy

* wrapper message ext encoder

* fix

* cleanup policy

* cleanup policy

* wrapper message ext encoder

* Revert "cleanup policy"

This reverts commit da76a4820b.

* cleanup policy

* topic compaction

* compaction recovery and user document

* use cleanup policy

* fix
2022-10-24 16:21:39 +08:00
mxsm 06a5496933 [ISSUE #5324]Replace deprecated class PosixParser with DefaultParser for CLI (#5325)
* [ISSUE #5324]Replace deprecated class PosixParser with DefaultParser for CLI

* fix bazel compile UpdateAccessConfigSubCommandTest testExecute failures

* Fixed bazel compile UpdateAccessConfigSubCommandTest testExecute failures
2022-10-19 22:43:06 +08:00
lizhiminsand斜阳 d663bcf6aa [ISSUE #5292] [RIP-48] Support reset offset in server-side to improve the success rate (#5293)
* [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>
2022-10-14 14:02:08 +08:00
mxsm db1f1839b9 [ISSUE #5298]Polish code style for jdk8+ (#5308) 2022-10-14 11:44:21 +08:00
NowinkeyandZhanhui Li 53e0847528 [ISSUE #5204] Enable checkstyle for test code (all module) (#5297)
* delete the checkstyle plugin for child modules

* [ISSUE #5204] Enable checkstyle for test code (all module)

* Exclude generated files

Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
2022-10-14 10:58:48 +08:00
Zhanhui Li d8c2930a20 [ISSUE #5276] Use OS pick-up port (#5280)
* Use OS pick-up port

* Replace deprecated PosixParser with DefaultParser for cli argument parsing

* DefaultParser cannot parse values that contain '=' character

* Revert changes to ServerUtil
2022-10-12 11:10:51 +08:00
rongtong 12e29df6db Fix the issue that AutoSwitchRoleIntegrationTest is flaky (#5277) 2022-10-11 18:44:22 +08:00
Nowinkey a5725c6b85 [ISSUE #5219] Enable checkstyle for test code (rocketmq-acl and rocketmq-tools) (#5220)
* style(acl):Enable checkstyle for test code

* style(tools):Enable checkstyle for test code
2022-09-29 11:46:56 +08:00
lizhimins 2c6ea9eeaf [ISSUE #5198] Fix NPE in ClusterList SubCommand (#5199) 2022-09-28 11:07:22 +08:00
lizhimins b8607d917c [ISSUE #5095] Support socks proxy in remoting client (#5123) 2022-09-28 10:22:55 +08:00
Zhanhui Li 5723b97964 [ISSUE #5126]Make all tests in ACL module pass on Windows (#5127)
* Make all tests pass on Windows

* Run in serial
2022-09-26 17:47:19 +08:00
zhoubo 251fc77957 Merge branch 'develop' into release-5.0.0 2022-09-23 10:28:18 +08:00
RapperCLandchenyong 91f98f3d51 remove unnecessary parameters (#5143)
Co-authored-by: chenyong <chenyong@highlight.mobi>
2022-09-21 09:48:54 +08:00
islongfei a4296a648b [ISSUE #5135] Format ERROR_MESSAGE string 2022-09-21 08:56:05 +08:00
hill ac82378aea [maven-release-plugin] prepare for next development iteration 2022-09-19 10:27:17 +08:00
hill f3e113cb1f [maven-release-plugin] prepare release rocketmq-all-5.0.0 2022-09-19 10:26:58 +08:00
Aaron Ai 1b011c1f50 [ISSUE #5108] Bump checkstyle to 3.2.0 (#5109)
* Bump checkstyle to 3.2.0

* Fix checkstyle
2022-09-19 10:10:29 +08:00
Aaron Ai c185c60b0f [ISSUE #5108] Bump checkstyle to 3.2.0 (#5109)
* Bump checkstyle to 3.2.0

* Fix checkstyle
2022-09-18 11:17:36 +08:00
zhangjidi2016andzhangjidi ad72dbee54 [ISSUE #5022] Optimize DefaultMQAdminExtImpl (#5023)
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
2022-09-08 11:00:26 +08:00
zhangjidi2016andzhangjidi 10e8e6b8ae [ISSUE #4487]The trackType is wrong when the consumer in broadcasting subscription (#4981)
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
2022-09-06 13:48:10 +08:00
Aaron Ai 4661e58ebe [ISSUE #4934] Checking for violations as part of build (#4935)
* Checking for violations as part of build

* Extend await time for FileWatchServiceTest#watchTwoFiles_ModifyOne
2022-08-31 10:55:04 +08:00
Aaron Ai f23fdbe016 Replace findbugs by spotbugs (#4931) 2022-08-30 17:45:56 +08:00
Zhanhui Li aae7b37d04 [ISSUE 4915] Identify flaky tests (#4919)
* 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
2022-08-29 19:52:53 +08:00
rongtong 36a5a5dedd Make all admin command descriptions begin with capital letters (#4912) 2022-08-28 20:30:27 +08:00
mxsm a961d1b44a [ISSUE #4817] Add a command to clear broker data from controller for CLI (#4823) 2022-08-27 19:42:55 +08:00
rongtong c411713836 [ISSUE #4894] Fix NPE in CommandUtil
[ISSUE #4894] Fix NPE in CommandUtil
2022-08-26 15:31:08 +08:00
Zhanhui Li 3da7ea9c1b [Infra Improvement] Build And Run Unit Tests in Parallel (#4878)
* 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)
2022-08-24 20:53:30 +08:00
YangJodie a5b6a5d4a8 [ISSUE apache#4858] fix ci fialed 2022-08-23 18:52:10 +08:00
YangJodie 17634d3317 [ISSUE apache#4858] add consumer type check for message direct push 2022-08-23 18:52:10 +08:00
RongtongJin bbbb96e129 Revert "Support build with Bazel (#4865)"
This reverts commit ec8a93d2f7.
2022-08-23 14:29:46 +08:00
Zhanhui Li ec8a93d2f7 Support build with Bazel (#4865)
* Support build with Bazel, fixing tests to make them capable of running in concurrency and hermetic.
2022-08-23 13:11:53 +08:00
rongtong a1dfb0197d Remove useless main function (#4867) 2022-08-22 18:00:54 +08:00
Aaron Ai 9e53567b8e [ISSUE #3998] Enable Github Action for CI Build (#4782)
* Enable Github Action for CI Build
2022-08-22 10:36:07 +08:00
allen 97521a3d8d [ISSUE #4849] Print message body while querying message, admin tools (queryMsgById&queryMsgByOffset) enhancement. (#4850) 2022-08-20 12:24:54 +08:00
HuiTong b7f0162ffa fix thread-safety problem of admin tools (#4843) 2022-08-19 12:26:47 +08:00
mxsm 06ca14a508 [ISSUE #4791] Add elect master command for admin CLI (#4798) 2022-08-11 10:06:46 +08:00