opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity
8,764 Commits 72 Branches 40 Tags
release-5.3.2
Commit Graph

8764 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
lizhimins 2baaf044ea [maven-release-plugin] prepare release rocketmq-all-5.3.2 (#9231) rocketmq-all-5.3.2 2025-03-08 14:07:17 +08:00
lizhimins 535a0787ad [ISSUE #9227] Prepare to release Apache RocketMQ 5.3.2 (#9228) 2025-03-07 15:45:26 +08:00
hqbfz ad60f33251 [ISSUE #9223] Pop consumer example add the default NamesrvAddr (#9224) 2025-03-07 13:47:35 +08:00
mxsm 5c34a59cd9 [ISSUE #9184] Optimize QueueLockManager#tryLock method (#9185) 2025-03-07 13:46:52 +08:00
hqbfz 343ed4ff46 [ISSUE #8127] Optimize the metric calculation logic of the time wheel (#8128) 
* Fix the metric of the time wheel was incorrectly calculated

* Fix the metric of the time wheel was incorrectly calculated

---------

Co-authored-by: wanghuaiyuan <wanghuaiyuan@xiaomi.com>
 2025-03-04 15:53:28 +08:00
yx9o 33a185a901 [ISSUE #9221] Extract some common code in BrokerPathConfigHelper (#9222) 2025-03-04 15:20:28 +08:00
lizhimins 40b25b36e0 [ISSUE #9217] Fix broker's inflight and available message counts incorrect when the pop consumer service is enabled (#9218) 2025-03-03 14:24:02 +08:00
qianye 988c826921 [ISSUE #9196] Broker return pop stats when receive notification (#9197) 2025-03-03 11:35:03 +08:00
lizhimins 53fdc4ad3d [ISSUE #9213] Fix get the earliest time error when data is clean up in tiered storage (#9214) 
* [ISSUE #9213] Fix get the earliest time error when data is clean up in tiered storag
 2025-03-03 09:58:06 +08:00
qianye 66d4a26eaa Optimize RocksDB CQ shutdown when using DoubleWriteCQ #9212 2025-02-28 14:19:38 +08:00
lizhimins 5936695b38 Revert "[ISSUE #9176] Fix pop message header missing fields when enable ACL 2…" (#9211) 
This reverts commit 5ca4dfe0a7.
 2025-02-28 09:52:46 +08:00
rongtong 19f799d936 [ISSUE #8340] RuntimeInfo and ClusterListSubCommand show ackThreadPoolQueueSize and ackThreadPoolQueueHeadWaitTimeMills (#8339) 
* RuntimeInfo and ClusterListSubCommand show ackThreadPoolQueueSize and ackThreadPoolQueueHeadWaitTimeMills

* RuntimeInfo and ClusterListSubCommand show ackThreadPoolQueueSize and ackThreadPoolQueueHeadWaitTimeMills
 2025-02-26 15:29:55 +08:00
fujian-zfj e805671c89 [ISSUE #9206] Fix slave sync topic sub in rocksdb ha (#9207) 
* typo int readme[ecosystem]

* fix slave sunc topic and sub in rocksdb ha mode
 2025-02-26 11:27:40 +08:00
阿洋 f2d4e0d7b3 [ISSUE #9203] Replace numbers with static variables defined in RequestCode 2025-02-25 08:09:53 +08:00
Quan 14156b4f0a [ISSUE #9191] Provide the ability to replace the remoting layer implementation for Proxy and Broker (#9192) 
* remoting replacement for proxy and broker

* add unit test

* fix code style
 2025-02-24 12:27:30 +08:00
Kris20030907 defcdc843c [ISSUE #9201] cleanup dead code patterns and improve readability and maintainability 2025-02-24 08:44:35 +08:00
zzl 5ca4dfe0a7 [ISSUE #9176] Fix pop message header missing fields when enable ACL 2.0 (#9179) 2025-02-21 14:17:03 +08:00
rongtong 6cccff82f4 [ISSUE #9187] The request should be rejected if the queueOffset equals maxOffset when changing the invisible time (#9186) 
* When changing the invisible time, the request should be rejected if the queueOffset equals maxOffset

* Add UTs

* Make UTs to pass

* Remove unused imports
 2025-02-19 17:24:50 +08:00
gaoyf 98308f616d [ISSUE #9182] Fix NameServer will be not ready forever when set needWaitForService to true (#9183) 
* Fix NameServer will be not ready forever when set needWaitForService to true

* Remove unused import
 2025-02-17 11:38:51 +08:00
ltamber 295821bd92 [ISSUE #9181] update fastjson version 
- 将 fastjson 依赖从 com_alibaba_fastjson 更新为 com_alibaba_fastjson2_fastjson2
- 此更改统一了 acl 模块中 fastjson 的使用版本

Signed-off-by: ltamber <ltamber12@gmail.com>
 2025-02-13 10:04:51 +08:00
lizhimins 61ea51252c [ISSUE #9172] Clean pull offset and reset offset when delete subscription group (#9173) 
* [ISSUE #9172] Clean pull offset and reset offset when delete subscription group

* [ISSUE #9174] Add a collection of predefined Groups and common checking methods in the MixAll (#9175)

Signed-off-by: ltamber <ltamber12@gmail.com>

* [ISSUE #9177] Fix unstable tests in AdaptiveLockTest.testAdaptiveLock  (#9178)

---------

Signed-off-by: ltamber <ltamber12@gmail.com>
Co-authored-by: ltamber <ltamber12@gmail.com>
Co-authored-by: hqbfz <125714719+3424672656@users.noreply.github.com>
 2025-02-12 19:09:55 +08:00
hqbfz d9d5e93135 [ISSUE #9177] Fix unstable tests in AdaptiveLockTest.testAdaptiveLock (#9178) 2025-02-12 16:44:34 +08:00
ltamber 6148b8993a [ISSUE #9174] Add a collection of predefined Groups and common checking methods in the MixAll (#9175) 
Signed-off-by: ltamber <ltamber12@gmail.com>
 2025-02-12 15:38:42 +08:00
yx9o c24f654909 [ISSUE #9156] Use fastjson2 in AclUtils#getAclRPCHook (#9157) 2025-02-10 10:40:59 +08:00
totalo faf494bd79 Restrict the list version workflow to be executed only in the main repository (#9168) 
* build: Restrict the Snapshot Daily Release Automation action to be triggered only in the official repository

* Restrict the list version workflow to be executed only in the main repository

* Restrict the list version workflow to be executed only in the main repository
 2025-02-10 08:28:39 +08:00
dingshuangxi888 0176ef4fac [ISSUE #9149]Assign offset in offsetTable even if the subscription key not exist. (#9150) 
* Assign offset in offsetTable even if the subscription key not exist.
 2025-02-06 16:48:31 +08:00
qianye 8086fc545d [ISSUE #9152] Broker getConsumeStats supports inputting multiple topics (#9153) 
* [ISSUE #9152] The getConsumeStats supports inputting multiple topics
 2025-02-05 14:41:53 +08:00
Lynx ff94b99758 [ISSUE #9155] Update doc Deployment Context 
Co-authored-by: lynx <lynx@qq.com>
 2025-01-28 10:08:32 +08:00
Matthew 208f832905 [ISSUE#9160] Ensure the requestCode increments sequentially 2025-01-28 10:08:00 +08:00
gaoyf de4e48d28a [ISSUE #9119] Invoke async should throw raw exception instead of CompletionException (#9120) 2025-01-17 11:44:32 +08:00
yx9o 4269dc5db9 [ISSUE #8728] Add more test coverage for TopicQueueMappingCleanService (#8729) 2025-01-16 13:54:04 +08:00
Kris20030907 a2755104b0 fix(comment): correct typos in ConsumeQueueExt class. (#9124) 2025-01-15 14:51:09 +08:00
Jax 14ca1ce654 [ISSUE #4570] fix: Docker usage may occur error in volume mapping params, simple fix (#9096) 2025-01-14 20:22:30 +08:00
qianye 7bcf919d88 [ISSUE #9128] Fix NPE when grpc client ack message immediately after changing proxy (#9129) 2025-01-14 16:01:28 +08:00
qianye 94d9185f2c [ISSUE #8895] Fix NPE when broker shutdown and optimize the log #9094 2025-01-14 14:50:56 +08:00
qianye b30afe8184 [ISSUE #9111] Support export broker RocksDB Config to json file (#9114) 
* [ISSUE #9111] Broker Support export RocksDB Config to json file and enhance admin tools
 2025-01-14 10:29:40 +08:00
Aurora Twinkle f6249e5b3a [ISSEU #6426] Fix slave broker SubscriptionGroupConfig and MessageRequestMode updating atomically (#8983) 
* fix[slave]:Make SubscriptionGroupConfig and MessageRequestMode updating atomically

* add unit test

* fix ut

---------

Co-authored-by: duanlinlin <duanlinllin@xiaohongshu.com>
 2025-01-13 14:45:20 +08:00
guyinyou 119a0bec66 [ISSUE #9121] Fix CRC32 Check Failing When Value is 0 2025-01-11 10:27:46 +08:00
lizhimins e0db6545b0 [ISSUE #9112] Speedup revive scan in Pop Consumption and support server side reset offset (#9113) 2025-01-08 23:00:22 +08:00
LilMosey a343021229 [ISSUE #9064] Optimize transaction message callback check logic (#9062) 2025-01-08 17:25:04 +08:00
yx9o b573df0cf3 [ISSUE #9108] Refactor ColdDataCgCtrService#getColdDataFlowCtrInfo (#9109) 2025-01-08 17:14:59 +08:00
rongtong 9ce83452a6 [ISSUE #9105] Fix the issue of duplicate consumption in LMQ (#9101) 
* Fix the issue of duplicate consumption in LMQ

* Pass the checkstyle

* Pass the UTs

* Pass the check style
 2025-01-06 10:51:58 +08:00
hqbfz 0548593b30 [ISSUE #8998] No retry is required when the remaining time reaches zero (#8999) 2025-01-06 10:23:47 +08:00
Liu Shengzhong 2538c3414d [ISSUE #9106] Fix revive backoff retry not effective in Pop Consumption based on rocksdb (#9107) 2025-01-06 10:03:34 +08:00
lizhimins a3afb05cb3 [ISSUE #9025] [RIP-73] Modify Pop Consumption rocksdb init config (#9100) 2025-01-03 19:39:35 +08:00
lizhimins f32fe78ca0 [ISSUE #9025] [RIP-73] Fix Pop Consumption reset offset (#9087) 2024-12-30 20:05:20 +08:00
lizhimins 7722ce78ee [ISSUE #9080] Not hold final message store config in fetcher (#9086) 2024-12-30 15:21:25 +08:00
imzs 19393e0475 [ISSUE #8974] Add feature switch of recalling, disable by default (#9067) 2024-12-27 13:56:09 +08:00
yuz10 2089abd3be [ISSUE #9080] Fix tranfer logic when get large messages from cache in tiered storage (#9079) 2024-12-26 14:49:00 +08:00
dingshuangxi888 1c35adb3dc [ISSUE #9075]Avoid message type validate in message sync scenario. (#9076) 
* Avoid message type validate in message sync scenario.
 2024-12-25 17:57:47 +08:00