opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 05:46:12 +08:00
Code Issues Packages Projects Releases Wiki Activity
7,579 Commits 72 Branches 40 Tags
0ae1bd2af69f475aba03ab7a27df0bd7cda15359
Commit Graph

7579 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
SSpirits 0ae1bd2af6 [ISSUE #5449] [RIP-46] implement remoting stats metrics (#5487) 
* implement remoting metrics

* fix bazel

* add metrics view & fix unit test

* move remoting command process timer to NettyDecoder
 2022-11-09 19:44:41 +08:00
mxsm 6ac321c1a0 [ISSUE #5482] Remove ClientRequestProcessor#getRouteInfoByTopic method invalid logic judgment (#5488) 2022-11-09 19:43:28 +08:00
zhangjidi2016 f4ff225649 [ISSUE #4487]Optimize the output of pressure results (#5282) 
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
 2022-11-09 19:33:41 +08:00
gongzhongqiang 4b3eafe260 Fix error core-concept url. (#5253) 
Co-authored-by: gongzhongqiang <gongzhongqiang@gigacloudtech.com>
 2022-11-09 19:33:10 +08:00
SSpirits 0ffb32f478 fix name server startup tip typo (#5491) 2022-11-09 18:12:50 +08:00
Humkum 6033983158 fix : npe caused by get item by logic offset if logic offset out of time (#5494) 2022-11-09 18:12:09 +08:00
Aaron Ai cca25fc525 Declare dependencies' version in maven properties (#5489) 2022-11-09 12:18:15 +08:00
jasonjavaYY 0d44ea183e modify variable name whichItemWorst to randomItem to resolve ambiguity (#5436) 2022-11-07 15:22:31 +08:00
mxsm 08bcd80681 [ISSUE #5446]Modify ScheduleMessageService's log name RocketmqStore to RocketmqBroker (#5447) 
* [ISSUE #5446]Modify ScheduleMessageService's log name RocketmqStore to RocketmqBroker

* Skip test case that is flaky on Windows

Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
 2022-11-07 15:21:37 +08:00
lizhimins 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
Humkum 9b2375dcf4 Add log info for push consumer when execute hook failed (#5468) 2022-11-07 11:59:55 +08:00
Dejan Varmedja e91a2fa746 [ISSUE #5430] Remove redundant null check (#5467) 
* Remove redundant null check

* Skip test cases for Mac that is flaky on the platform

* Disable PopBufferMergeServiceTest#testBasic on Windows

* Use MockitoJUnitRunner.Silent for PopBufferMergeServiceTest

Co-authored-by: Zhanhui Li <lizhanhui@gmail.com>
 2022-11-07 11:13:13 +08:00
Zhanhui Li 130fb0c504 Enable checks on Windows and MacOS (#5459) 2022-11-04 14:35:59 +08:00
echooymxq d7321fee50 Fix windows can't move file when mmapped. (#5434) 2022-11-03 18:01:49 +08:00
Zhanhui Li 61fa3b0c23 [ISSUE #5344] Fix Windows and Mac CI pipelines (#5345) 
* Skip tests that are not compatible with Windows using org.junit.Assume

* Skip incompatible test case

* Ignore cases that is not compatible with Windows

* Skip a test case on Mac to make CI pass

* Skip test case on Windows if load() fails

* Try to grant more time to TlsTest to make Mac CI pass

* Grant longer potential duration for await
 2022-11-03 11:15:55 +08:00
mxsm 3963c754ed [ISSUE #5453]Combine parseDelayLevel error log information (#5454) 2022-11-02 20:53:28 +08:00
SSpirits 350e433acc implement broker stats metrics and request metrics (#5449) 
* implement broker stats metrics and request metrics

* fix bazel

* PopBigMessageIT potentially needs more time

* Fix bazel deps warning

Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
 2022-11-02 20:42:42 +08:00
rongtong d45a34c0a5 Fix ServiceProvider report NPE misleading users when no resource file found (#5450) 2022-11-02 19:17:24 +08:00
rongtong dd95a5b9c8 Fix Label '@maven//:com_google_guava_guava' is duplicated in the 'deps' attribute of rule 'tests' to pass CI (#5451) 2022-11-02 17:42:12 +08:00
lk 58c79c9f13 [ISSUE #5365] [RIP 51] Add notification mechanism for pop orderly (#5387) 
* [ISSUE #5365] Add notification mechanism for pop orderly

* [ISSUE #5399] add guava dependency for the test of store in BUILD.bazel
 2022-10-31 13:32:14 +08:00
mxsm 527704d964 [ISSUE #5413] Modify AutoSwitchHAClient currentReceivedEpoch attribute long type to int 2022-10-31 10:46:53 +08:00
RapperCL 6af6fedd05 [ISSUE #5415] Fix duplicate records (#5416) 
* fix duplicate records

* code update
 2022-10-31 10:44:41 +08:00
mxsm 520721d527 [ISSUE #5426] Fix mqadmin updateTopic CLI result print format problem (#5427) 2022-10-31 10:34:17 +08:00
RapperCL dd4b666435 [ISSUE #5424] Fix null exception and array overflow bug exist in getHalfMsg method #5425 2022-10-31 10:27:54 +08:00
zhangjidi2016 86bc27eb24 [ISSUE #5310] Fix admin tool queryMessage signature check failed (#5319) 
* [ISSUE #5310] Fix admin tool queryMessage signature check failed

* Compatible with versions less than 4.9.4

Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
 2022-10-28 14:26:28 +08:00
SSpirits 4ba8aa238d [ISSUE #5354] [RIP-46] Implement proxy metrics framework (#5407) 
* implement proxy metrics framework

* fix bazel dependency

* fix proxy startup test

* fix warning in bazel test

* minor improve
 2022-10-27 17:23:31 +08:00
lk 83540fca6a [ISSUE #5408] can skip ack when cannot find matching ck for a long time (#5409) 2022-10-27 17:14:09 +08:00
Nowinkey 7a4fa6b96e [ISSUE #5307] Remove redundant if statements (#5314) 2022-10-27 16:35:41 +08:00
Ruantihong 5d0db77f0c [RIP-50]RocketMQ Transaction Message Improvement Of Batch OP Message (#5386) 2022-10-27 16:15:49 +08:00
echooymxq c108124078 [ISSUE #5331]Fix ConsumeQueueTest stable sleep cause NPE. (#5397) 
* [ISSUE #5331]Fix ConsumeQueueTest stable sleep cause NPE.

* Use awaitability to achieve granular condition check

* Add a timeout duration for condition check

* Add a timeout duration for condition check

Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
 2022-10-27 16:13:28 +08:00
lk d54f8cb1eb [ISSUE #5402] not to decompress the body of messages when get retry messages in PopReviveService (#5403) 2022-10-27 15:32:51 +08:00
lizhimins 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
lk 40013b32e8 [ISSUE #5390] not to print some useless log in PopReviveService (#5391) 2022-10-25 10:10:34 +08:00
rongtong 0e3f8b4d72 Fix the issue that TransactionMessageIT can not pass (#5394) 2022-10-24 18:45:05 +08:00
xiaoyifang a2d52ef159 [ISSUE #5373] output namesrv bindaddress when starting (#5369) 
[ISSUE #5373] output namesrv bindaddress when starting (#5369)

Co-authored-by: xiaoyifang <xiaoyifang@foxmail.com>
 2022-10-24 17:06:12 +08:00
Lq Wang 865d7043be [ISSUE #5381] Optimize merge_rocketmq_pr.py comments (#5389) 2022-10-24 16:28:19 +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
caigy 4af193e325 [ISSUE #5012] Support escaping transactional messages (#5062) 
* 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
 2022-10-24 14:28:00 +08:00
lk 03ffc45a8b [ISSUE #5364] Support changeInvisibleTime for pop orderly (#5367) 2022-10-24 10:44:06 +08:00
thezp 465ba21371 [ISSUE #5372] remove second call on fileWatchService's shutdown method (#5379) 
Co-authored-by: zhangpeng <Nari@2021>
 2022-10-24 10:42:00 +08:00
echooymxq debd7b62b6 [ISSUE #5374] Fix unregister cause the new master removed. (#5375) 2022-10-21 20:28:20 +08:00
SSS-K e863f485ce [ISSUE #5376] Fix use of broker config timerMaxDelaySec 2022-10-21 20:27:48 +08:00
mxsm 5ab7b0d128 [ISSUE #5370]Upgrade commons-cli version to 1.5.0 in WORKSPACE (#5371) 2022-10-21 19:14:45 +08:00
lizhimins c4227b2357 [ISSUE #5348] [RIP-48] Support server-side offset management in broadcast consumption mode (#5349) 
* Support server-side offset management in broadcast consumption mode
* Fix unit test npe and and offset store test
* Fix fast encode decode test

Co-authored-by: 斜阳 <terrance.lzm@alibaba-inc.com>
 2022-10-21 16:24:12 +08:00
SSpirits 6e27b54349 [ISSUE ##5354] Implement broker metrics framework (#5355) 
* implement broker metrics framework

* update bazel config

* Fix Bazel deps

* Fix unnecessary mocking issue

* Fix bazel compile warning

Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
 2022-10-19 23:14:45 +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
Zhouxiang Zhan c9c8a0a61a Add unit test for ConsumerProcessor (#5352) 2022-10-19 17:37:28 +08:00
mxsm 3df28420ba [ISSUE #5332]Remove DefaultMessageStore's private field printTimes that is never used (#5336) 
* [ISSUE #5332]Remove DefaultMessageStore's private field printTimes that is never used

* Remove unused imports

Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
 2022-10-18 17:42:22 +08:00
Jixiang Jin c99a593f43 Upgrade proto version to 2.0.1, and adapt to parse dlq information. (#5343) 
* Upgrade proto version to 2.0.1, and adapt to parse dlq information.

* Upgrade proto version to 2.0.1 in bazel config.
 2022-10-18 17:20:35 +08:00
rongtong e241e160a5 [ISSUE #5339] Fix BrokerContainer document error 2022-10-18 13:44:28 +08:00