opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-25 10:03:57 +08:00
Code Issues Packages Projects Releases Wiki Activity
9,105 Commits 75 Branches 40 Tags
codex/fix-rocksdb-options-test
Commit Graph
379 Commits
Author SHA1 Message Date
lizhimins 9443c6d9db [ISSUE #10383] Align Bazel dependencies with Maven pom.xml (#10404) 2026-05-29 10:04:20 +08:00
yx9o 7c10c7707d [ISSUE #10154] Rename BrokerConsumeStatsSubCommad to BrokerConsumeStatsSubCommand (#10155) 2026-03-17 10:28:42 +08:00
Quanimzszhouli11
 		1b6a919bde [RIP-83] Lite Topic: A New Message Model (#9800) 
Co-authored-by: imzs <imzs@foxmail.com>
Co-authored-by: zhouli11 <04081337@163.com>
 2026-01-16 17:20:22 +08:00
majialong 4c665802a2 [ISSUE #9994] Improve switchTimerEngine command with OptionGroup validation (#9995) 2026-01-08 14:19:37 +08:00
rongtongandRongtongJin 02412eba59 [ISSUE #9933] Fix the failure when RocksDBConfigToJsonCommand exports locally. (#9934) 
Co-authored-by: RongtongJin <user@example.com>
 2025-12-19 10:03:30 +08:00
yx9o 8c7bf5225a [ISSUE #9902] Remove unnecessary String.format (#9903) 2025-12-18 20:00:21 +08:00
yx9o beee84fa44 [ISSUE #9868] Fix getBrokerEpoch no response issue for empty parameters (#9869) 2025-12-12 16:26:48 +08:00
Drizzledrizzle.zkzhouli11
 		7a08b4cb68 [RIP-82] Implement Timer message, transaction message, and index based on RocksDB (#9787) 
* add isWakeCommitWhenPutMessage  for AIO

* Implemented Timer message, Transaction Message, Index based on rocksdb

* add timeline roll interval can be config

* optimize the code

* optimize the code

* add sone logic for recover commitlog

* optimize the code

* update

* update

* optimize the code

* update

* update

* optimize the code

* optimize the code

* update

* update

* update

* update

* update

* update

* update

* update

* update

* update

* update

* update

Change-Id: I700798ef625187ac32c16c8ea5aae5f2debfdddf

* update

Change-Id: I1d2dfa24317d2ad7c0ca41d90cd2b3c1ba260b0b

* update

Change-Id: I974e30eb909722ea2a17a14e505759bf20f4f860

* update

Change-Id: Ica01fbd08a2d60e9a0f4ab54b41ae4768cc4fa5d

* update

Change-Id: I764ce6cea3159b025bf1e6e65b60e20514cecb4f

* update

Change-Id: I0cc735896e1266934293ec06cb4f07746a1894a1

* update

Change-Id: I6538b6a60631c62e162bf511ae20185a07b72508

* update

Change-Id: I03f83b9e8199f3595ca28471df4a2e94671fbaae

* update

Change-Id: I5b19b671fa0b40cd2aba63f1d0eb654b92775cb4

* update the code

Change-Id: I22788d112b7f214310719e2d3ebad839ef818e67

* update

Change-Id: I7da89fe635b58ac5026095a8e484fa46f68521e7

* update the code

Change-Id: I5eade6c31803b8cf05c1a4bb83c226d57f4980c7

* update

Change-Id: Id67f600fad1a876926cd505dba047cc82011160c

* update

Change-Id: Ia4b0e2a21aa5e12570a80713432fd48ddfb210e6

* optimize the code

Change-Id: Idf8080c7b17c25e14fe34ef6bad1e1150dab58d6

* update

Change-Id: I904f0120a728b4eb87226159f9c0cde3d18ef26a

* update code

Change-Id: I21653d6bcad905daa8f10d12298d1d27535af9d9

* update

Change-Id: I712b9cde9a18c730fd020ea76f05560e594a9edd

* update

Change-Id: Iafe10c007e9b5057212e2dcfb21671f970b1d344

* update

Change-Id: I40c1c7f54852ee033e0caa22573436ee505a27b8

* optimize the code

Change-Id: Iae006b01608df4f363c63a0ae876dbf63cd56fbd

---------

Co-authored-by: drizzle.zk <drizzle.zk@alibaba-inc.com>
Co-authored-by: zhouli11 <04081337@163.com>
 2025-12-11 15:13:56 +08:00
yx9o d7e27d6d69 [ISSUE #9396] Use fastjson2 in all modules (#9397) 
* Use fastjson2 in all modules

* Update test

* Update test

* Update test

* Add serialization compatibility test tool class

* Update RemotingSerializableCompatTest.java

* Update RemotingSerializableCompatTest.java

* Update RemotingSerializableCompatTest.java

* Update BitSet problem

* Update

* Update

* Update test

* Update test

* Update BUILD.bazel

* Update BUILD.bazel

* Update test

* Update BitSet problem

* Add test

* Add compat test

* merge develop

* Update test

* merge develop
 2025-12-04 19:09:08 +08:00
yx9o 9f58198abd [ISSUE #9883] Remove unnecessary MessageFormat.format (#9884) 
* [ISSUE #9883] Remove unnecessary MessageFormat.format

* Update import
 2025-12-03 13:51:13 +08:00
yx9o 12f8db1e23 [ISSUE #9821] Fix getBrokerConfig no response issue for empty parameters (#9822) 
* [ISSUE #9821] Fix getBrokerConfig no response issue for empty parameters

* Update

* Update test
 2025-11-12 11:18:40 +08:00
Michael HauseggerandTheRealHaui e7d930f585 Fixed error message of CommandUtil.fetchMasterAddrByBrokerName (#9825) 
Co-authored-by: TheRealHaui <michael.hausegger@hausegger.tech>
 2025-11-08 16:08:08 +08:00
qianye 2eb21293cf [ISSUE #9773] Implement Shared RocksDB Instance for Broker Configs (#9774) 2025-10-23 15:31:41 +08:00
lizhimins 4c06b15b8b [ISSUE #9739] Revert skipped test cases in macos environment (#9749) 2025-10-13 20:58:33 +08:00
guyinyouandguyinyou 0e72809335 [ISSUE #9705] Improve persist() method reliability to prevent broker startup failure after power outages (#9706) 
* fix: prevent broker startup failure after power outage

- Add atomic file backup mechanism in persist() methods
- Delete corrupted config files during startup to avoid bak file pollution
- Add directory sync to ensure file operations visibility

Fixes: TimerMetrics#persist, TransactionMetrics#persist, ConfigManager#persist

* remove "Shutdown" implements

* empty commit

* add SuppressWarnings

* fix ut

* fix ut

* pass rocksdb ut when isMac()

* pass rocksdb ut when isMac()

* pass rocksdb ut when isMac()

* pass rocksdb ut when isMac()

* pass RocksdbGroupConfigTransferTest ut when isWindows()

* pass Rocksdb ut when isMac()

---------

Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2025-09-18 22:32:19 +08:00
cvictoryandcvictory 1c23a8094a [ISSUE #9663] Adopt Maven's revision mechanism (requires Maven >= 3.5.0) (#9665) 
Co-authored-by: cvictory <shengli.caosl@alibaba-inc.com>
 2025-09-04 09:51:02 +08:00
Hongxu Xu 7ab7ddd6d2 [ISSUE #9609] Fix bazel CI and reduce dependencies (#9610) 2025-08-22 16:35:39 +08:00
ltamberandxiaoming.lt 7cb1b1ee86 [ISSUE #9467] Implement paged retrieval of Topic and SubscriptionGroup information (#9468) 
* Implement paged retrieval of Topic and SubscriptionGroup information
- Implemented pagination logic to support data retrieval by sequence number and maximum count.
- Added data version checking to ensure the retrieved data is the latest.
- Optimized the result structure to include total count and current page data.
- Added unit tests

* BrokerOuterAPI

* add timeout & log

---------

Co-authored-by: xiaoming.lt <xiaoming.lt@alibaba-inc.com>
 2025-07-02 09:36:54 +08:00
WJ66880 f4e2a4a0e3 [ISSUE #9335] Use MixAll.ROCKETMQ_HOME_DIR for home directory (#9474) 2025-06-18 10:28:35 +08:00
lizhimins aecb97ec44 [maven-release-plugin] prepare for next development iteration (#9389) 2025-05-07 16:34:04 +08:00
lizhimins 29d90a4ff9 [maven-release-plugin] prepare release rocketmq-all-5.3.3 (#9388) 2025-05-07 09:48:32 +08:00
dingshuangxi888 ade18bb076 [ISSUE 9362] [RIP-77] Deprecate and Remove ACL 1.0 (#9363) 2025-04-30 15:02:55 +08:00
ymwneu d5b474d9d3 [ISSUE #9297] Supports outputting topic put TPS in TopicStatusSubCommand (#9298) 2025-04-02 18:59:45 +08:00
lizhimins 47fe6b2ba6 [maven-release-plugin] prepare for next development iteration (#9232) 2025-03-08 17:20:49 +08:00
lizhimins 2baaf044ea [maven-release-plugin] prepare release rocketmq-all-5.3.2 (#9231) 2025-03-08 14:07:17 +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
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
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
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
lizhimins 35a6426ea9 [ISSUE #9025] [RIP-73] Pop Consumption Improvement Based on RocksDB (#9048) 2024-12-20 20:37:25 +08:00
rongtong bf2f2a7774 Fix incorrect path for exportMetadataInRocksDBCommand (#8941) 2024-11-18 17:25:20 +08:00
LetLetMe 0b24768500 [ISSUE #8822] Double write cq, reduce unnecessary switches (#8823) 
* Reduce unnecessary switches
 2024-10-29 19:09:35 +08:00
Zhanhui Li b86059c7c1 Support LMQ dispatch in case if Consume Queue Store is RocksDB-based (#8842) 
* feat: support LMQ dispatch

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* fix: introduce group-commit for batch insertion of RocksDB KV pairs

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* fix: propagate store error to broker module

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* chore: fix all Bazel warning and errors

Signed-off-by: Zhanhui Li <lizhanhui@gmail.com>

* fix: remove unnecessary batch-ops when writing RocksDB using atomic flush

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* fix: find a writable directory for RocksDB logs

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* chore: clean up ConfigHelperTest

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* fix: truncate consume queues in case commit log records are truncated

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* fix: truncate LMQ max offsets

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* fix: correct truncate boundary of consume queues

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* fix: correct MessageExt encoding

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* chore: remove unused import

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

---------

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Signed-off-by: Zhanhui Li <lizhanhui@gmail.com>
 2024-10-23 09:56:37 +08:00
rongtong 483a48a130 PrintMessageSubCommand support lmq (#8785) 2024-10-09 09:58:05 +08:00
lizhimins daf3d1a666 [maven-release-plugin] prepare for next development iteration (#8750) 2024-09-26 09:33:52 +08:00
lizhimins b122c8109d [maven-release-plugin] prepare release rocketmq-all-5.3.1 (#8749) 2024-09-25 23:24:56 +08:00
LetLetMe 3b5cbf86df [ISSUE #8698] Remove batch write in kv cq store and update rocksdb cq check tool (#8739) 2024-09-25 19:32:47 +08:00
yuz10 e2abbc31d9 [ISSUE #8740] fix rocksDBConfigToJson command (#8738) 
* fix rocksDBConfigToJson command

* fix
 2024-09-25 10:14:38 +08:00
LetLetMe 525f877f3b [ISSUE #8589] Support file format CQ and json format offset in-place upgrade to rocksdb management (#8600) 2024-09-23 19:24:15 +08:00
rongtong e5e38396ba [ISSUE #8591] Preliminary support for key commands of LMQ (#8590) 
* Preliminary support for key commands of LMQ

* Preliminary support for key commands of LMQ

* Optimize some code

* Fix some bugs and UTs for lmq support

* Fix UTs can not pass

* Fix UTs can not pass

* Add some check to prevent NPE
 2024-08-30 14:15:03 +08:00
caigy a1ea1eb1f2 [ISSUE #8576] Support Creating or Updating Subscription Groups in Batch 
support creating or updating groups in batch

support creating or updating groups in batch

support creating or updating groups in batch
 2024-08-27 15:21:53 +08:00
LetLetMe 2a938fb1bc [ISSUE #8058] Support for upgrading metadata in json to rocksdb (#8571) 2024-08-23 11:18:03 +08:00
lizhimins 5dc0c6a8b5 [maven-release-plugin] prepare for next development iteration (#8382) 2024-07-09 01:30:43 +08:00
lizhimins 7ee50ec32e [maven-release-plugin] prepare release rocketmq-all-5.3.0 (#8379) 2024-07-08 23:15:33 +08:00
hqbfz 3ecc73bcc4 [ISSUE #8278] Fix fail test (#8279) 
* fix fail test

* fix fail test
 2024-06-11 09:08:32 +08:00
guyinyouguyinyougaoyang.cgy
 		4be8fd4372 [ISSUE #8265] Implement Batch Creation of Topics in RocketMQ Admin (#8267) 
* add UPDATE_AND_CREATE_TOPIC_LIST

* support creating or updating topic config in batch


---------

Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
Co-authored-by: gaoyang.cgy <gaoyang.cgy@alibaba-inc.com>
 2024-06-07 10:28:36 +08:00
dingshuangxi888 e1339ac8a0 [ISSUE #7560] [RIP-68] Support RocketMQ ACL 2.0 (#7725) 
[ISSUE #7560] [RIP-68] Support RocketMQ ACL 2.0 (#7725)
 2024-03-18 14:07:51 +08:00
rongtong f41160210a [maven-release-plugin] prepare for next development iteration (#7828) 2024-02-12 11:07:03 +08:00
rongtong 281a7b32f0 [maven-release-plugin] prepare release rocketmq-all-5.2.0 (#7827) 2024-02-11 17:53:50 +08:00
Zhouxiang Zhan b1d8d306a5 [ISSUE #7699] Add namespace v2 in client (#7700) 
* Add namespace v2

* Add NamespaceRpcHook

* Refector extends header

* Use Boolean in request header to remove unnecessary encode

* Add unit test

* Add NamespaceRpcHookTest

* Remove GrpcConverter#wrapResourceWithNamespace

* Optimize readability of RpcRequestHeader
 2024-01-12 10:46:15 +08:00