Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1666 commits
Select commit Hold shift + click to select a range
0f6b427
[ISSUE #9501] correcting mismatched comments (#9502)
yx9o Jul 4, 2025
3d94585
fix (#9516) Return origin handle to consumer when changeInvisibleDura…
qianye1001 Jul 8, 2025
ecd78d9
fix (#9526) Fix combineCQ extra search commitLog files for recovery
qianye1001 Jul 8, 2025
9337904
[ISSUE #9309]opti:Avoid the generation of dirty data in #assignResetO…
3424672656 Jul 9, 2025
1a747d1
opti: opti thread count in adaptiveBackOffSpinLock (#9530)
3424672656 Jul 10, 2025
2accb97
[ISSUE #9520] Remove unnecessary topicConfig data version change when…
RongtongJin Jul 10, 2025
8639dcc
[ISSUE #9254] Optimize the logs of the message store (#9528)
qianye1001 Jul 11, 2025
76cee72
[ISSUE #9537] MQClientAPIFactory Implement NameServerUpdateCallback i…
qianye1001 Jul 11, 2025
d8fa28c
[ISSUE #9544] Must correct file size when init the file segment (#9545)
lizhimins Jul 14, 2025
e4b731c
[ISSUE #9539] Fix compare policy entry logic in ACL 2.0 (#9540)
1782935682 Jul 14, 2025
9c1ca2a
Remove the meaningless brokerVersion (#9533)
RongtongJin Jul 15, 2025
1f24f09
[ISSUE #9555 ]fix the npe in the hashCode method when subscriptionDat…
1782935682 Jul 19, 2025
40e3aa9
[ISSUE #9553] Improve performance by avoiding repeated get(key) (#9554)
yx9o Jul 20, 2025
438077e
Limit group max length to 120. (#9563)
lollipopjin Jul 22, 2025
e20d56b
[ISSUE #9254] Refactor notifyMessageArriveInBatch in RocksDBConsumeQu…
qianye1001 Jul 23, 2025
100f467
[ISSUE #9572] Unnecessary code comment cleanup (#9573)
yx9o Jul 28, 2025
2791833
Fix typos (#9560)
co63oc Jul 28, 2025
f798f96
[ISSUE #9254] Optimize innerConsumeQueueStoreList order in CombineCon…
qianye1001 Aug 6, 2025
9609722
[ISSUE #9596] Optimize log in invokeSync when addr is null (#9597)
1782935682 Aug 6, 2025
6d4fb83
[ISSUE #9605] Fixed a potential resource leak (#9606)
yx9o Aug 9, 2025
9e2445e
[ISSUE #9589] Optimize broker metrics initialization (#9598)
qianye1001 Aug 12, 2025
c05dcdc
[ISSUE #9611] Should exec callback in the Pop based on rocksdb impl (…
lizhimins Aug 12, 2025
f40a69f
fix: remove wrong logic in the callback for sending messages in rpc (…
3424672656 Aug 12, 2025
e6a587a
[ISSUE #9626] Prevent premature offset commit before consumer record …
lizhimins Aug 22, 2025
7ab7ddd
[ISSUE #9609] Fix bazel CI and reduce dependencies (#9610)
xuhongxu96 Aug 22, 2025
2954655
[ISSUE #9652] Enhance test for MQClientInstance (#9653)
GabrielDUX Sep 1, 2025
74ab3ae
[ISSUE #9648] Fix getOffsetInQueueByTime missing boundaryType in tier…
GabrielDUX Sep 2, 2025
365b297
[ISSUE #7837] Fix start() and shutdown() of DefaultMessagingProcessor…
redlsz Sep 3, 2025
1c23a80
[ISSUE #9663] Adopt Maven's revision mechanism (requires Maven >= 3.5…
cvictory Sep 4, 2025
632dc32
[ISSUE #9650] Unified FAQ related URLs (#9651)
yx9o Sep 4, 2025
2f89371
[ISSUE #9620] placeholder replacement string concatenation (#9621)
yx9o Sep 5, 2025
32d68e7
[ISSUE #9581] Optimize the resource bloat of pollingMap and topicCidM…
RongtongJin Sep 8, 2025
40622ce
[ISSUE #9764] Fix bazel-compile (ubuntu-latest) error (#9675)
yx9o Sep 9, 2025
86e8ed6
[ISSUE #9666] Add accelerated startup recovery feature for RocksDB st…
RongtongJin Sep 9, 2025
bb45b8f
[ISSUE #9634] Improve BrokerContainer extensibility and module struct…
RongtongJin Sep 9, 2025
ce5a77d
[ISSUE 9547] Fix sync group if attributes isn't null
1782935682 Sep 10, 2025
809bfe6
[ISSUE #9682] Increase initial delay for scanning inactive brokers to…
mxsm Sep 10, 2025
c3c6832
[ISSUE #9680] Improve RocksDB compaction filter factory resource mana…
RongtongJin Sep 11, 2025
7967edf
[ISSUE #9677] Resolve metrics static variable conflicts in BrokerCont…
RongtongJin Sep 11, 2025
edaffe6
[ISSUE #9695] Not use pull offset when use pop orderly consume (#9696)
lizhimins Sep 12, 2025
4ae0294
[ISSUE #9693] Add writeWithoutMmap configuration to prevent JVM crash…
guyinyou Sep 14, 2025
02f413d
[ISSUE #9701] Synchronize metrics shutdown to prevent JVM crashes dur…
guyinyou Sep 15, 2025
d0e31a2
[ISSUE #9703] Remove pull offset and reset offset when deleting topic…
qianye1001 Sep 16, 2025
1d9b02c
[ISSUE #9707] Integrate RunningFlags with MappedFile system for bette…
guyinyou Sep 16, 2025
93f60db
[ISSUE #9713] Improve data consistency in DefaultMappedFile flush method
guyinyou Sep 16, 2025
73e8fdb
[ISSUE #9699] Optimize shutdown process and resource management (#9700)
RongtongJin Sep 17, 2025
0e72809
[ISSUE #9705] Improve persist() method reliability to prevent broker …
guyinyou Sep 18, 2025
dbd935f
[ISSUE #9709] Add enableRunningFlagsInFlush configuration switch for …
guyinyou Sep 19, 2025
47c07a9
[ISSUE #9716] refactor: replace RandomAccessFile with FileChannel (#9…
RongtongJin Sep 19, 2025
8fc57f1
[ISSUE #9717] Fix RaftBrokerHeartBeatManager#scanNotActiveBroker was…
redlsz Sep 19, 2025
fbe9f73
[ISSUE #9721] Fix TimerDequeueGetService thread not exiting after shu…
RongtongJin Sep 21, 2025
aa9ee1d
[ISSUE #9689] Fix the issue that master transfer epoch was not update…
redlsz Sep 22, 2025
7d75021
[ISSUE #9719] Fix Static Variable Conflicts in Multi-Broker Metrics M…
RongtongJin Sep 22, 2025
a4da5f5
[ISSUE #9723] Fix missing "+" symbol in metadata updates for v2 confi…
cvictory Sep 22, 2025
d197028
refactor: abstract StoreMetricsManager interface to support non-Defau…
RongtongJin Sep 24, 2025
6d6921b
[ISSUE #9687] Cleanup BrokerHeartbeatManager code (#9688)
majialoong Sep 24, 2025
64999c1
[ISSUE #9732] Fix request may still be invoked when local process tim…
qianye1001 Sep 25, 2025
1c83b11
[ISSUE #9658] Replace JUnit 5 imports with JUnit 4 (#9659)
yx9o Sep 29, 2025
060e4dc
[ISSUE #9743] Fix ReceiptHandleProcessorTest (#9744)
yx9o Oct 9, 2025
4b5f866
Fix typos and linguistic errors in documentation (#9748)
survivant Oct 9, 2025
b1a7ac8
fix get dledger mod storepath (#9746)
LittleBoy18 Oct 9, 2025
40ca80e
[ISSUE #9741] Optimize authentication whitelist lookup efficiency (#9…
yx9o Oct 13, 2025
4c06b15
[ISSUE #9739] Revert skipped test cases in macos environment (#9749)
lizhimins Oct 13, 2025
4a64a5a
[ISSUE #9750] Fix NPE when isAsyncSendEnable is false (#9751)
RongtongJin Oct 14, 2025
3dd4bfd
[ISSUE #9756] Fix the issue where the port is always 10911 when start…
RongtongJin Oct 15, 2025
4c46038
[ISSUE #9752] Fix time dequeue latency unit to milliseconds (#9753)
dingshuangxi888 Oct 15, 2025
4859db9
[ISSUE #9761] Fix get authentication and authorization metadata provi…
majialoong Oct 16, 2025
e6ec760
[ISSUE #9758] Fix resource filter does not take effect in the listAcl…
majialoong Oct 16, 2025
6da83fa
[ISSUE #9765] Improve null handling in file operations (#9766)
yx9o Oct 21, 2025
ccdf9a6
[ISSUE #9767] Fix incorrect decode method for UnlockBatchRequestBody …
majialoong Oct 22, 2025
a2747da
[ISSUE #9769] Add tls.ciphers and tls.protocols in system properties …
carlvine500 Oct 22, 2025
08b62b9
refactor: remove static from executorService to support multi-broker …
RongtongJin Oct 22, 2025
035c91a
[ISSUE #9763] Fix invalid user disable status check in authorization …
majialoong Oct 23, 2025
2eb2129
[ISSUE #9773] Implement Shared RocksDB Instance for Broker Configs (#…
qianye1001 Oct 23, 2025
e262890
[ISSUE #9776] Make SharedByteBuffer size configurable via MessageStor…
RongtongJin Oct 24, 2025
bea086f
[ISSUE #9773] Fix core dump when shutdown broker twice
qianye1001 Oct 27, 2025
204b251
Correct method name from updateDateVersion to updateDataVersion (#9788)
majialoong Oct 30, 2025
d7c8bb7
[ISSUE #9784] Fix the policy comparator to prioritize DENY over ALLOW…
majialoong Nov 3, 2025
6b91c7d
[ISSUE #9798] Reduce unnecessary thread switching in sending message …
qianye1001 Nov 6, 2025
440341b
[ISSUE #9811] Fixed the issue of excessive loop iterations in reput s…
lizhimins Nov 6, 2025
736d2a8
[ISSUE #9816] Fix concurrent modify opentelemetry record in calculate…
lizhimins Nov 7, 2025
455305a
[ISSUE #9813] Fix buffer fetch thread pool starvation in tiered stora…
lizhimins Nov 7, 2025
e7d930f
Fixed error message of CommandUtil.fetchMasterAddrByBrokerName (#9825)
TheRealHaui Nov 8, 2025
35a7474
[ISSUE #9802] Fix the issue of delete logic in tiered storage index s…
lizhimins Nov 10, 2025
607263b
upgrade OpenTelemetry to version 1.44.1 (#9820)
RongtongJin Nov 10, 2025
29a62c4
[ISSUE #9735] Add TimerWheel snapshot mechanism for reliable recovery…
guyinyou Nov 10, 2025
e4170f5
Add timestamp query message offset to abstract class (#9836)
lizhimins Nov 11, 2025
12f8db1
[ISSUE #9821] Fix getBrokerConfig no response issue for empty paramet…
yx9o Nov 12, 2025
f0d3b9c
[ISSUE #9794] Change JDK prerequisite from 1.7+ to 1.8+ in documentat…
yx9o Nov 12, 2025
e2be0f2
fix controller mode scanControllerAddress (#9845)
LittleBoy18 Nov 12, 2025
7a1a950
[ISSUE# 9841] Improve Resource Management in TimerWheel to Prevent Fi…
guyinyou Nov 12, 2025
3b78ab0
[ISSUE #9632] Fix Pop Long-polling Not Awakened for V1 Retry Messages…
qianye1001 Nov 12, 2025
e60b67a
[ISSUE #9838] IndexStoreService use forceShutdown when disk is not wr…
RongtongJin Nov 13, 2025
2017630
[ISSUE #9834] Support writeWithoutMmap in IndexStoreFile (#9835)
RongtongJin Nov 13, 2025
69e2524
Fix resource leak in IndexStoreFile shutdown (#9840)
RongtongJin Nov 14, 2025
6c798d6
[ISSUE #9593] Optimize Deflater resource release (#9594)
yx9o Nov 14, 2025
9c3e7fe
[ISSUE #9847] Reduce lock contention on the HandleData object to prev…
qianye1001 Nov 14, 2025
d750461
[ISSUE #9857] Optimize the performance of the notification by removin…
qianye1001 Nov 18, 2025
d08f787
[ISSUE #9807] Optimize log.warn Time Consumption in the send Method (…
yx9o Nov 19, 2025
7acfe4d
[ISSUE #9737] Fix client memory leak on connection failure (#9740)
qianye1001 Nov 19, 2025
8eabe68
[ISSUE #9849] Correct ACL cache loader error log in ClusterMetadataSe…
majialoong Nov 20, 2025
963c0e2
[ISSUE #9741] Optimize authorization whitelist lookup efficiency (#9760)
majialoong Nov 20, 2025
a68a5bf
[ISSUE #9809] Fix NPE in getAcl when subject is null (#9810)
majialoong Nov 20, 2025
ccf9730
[ISSUE #9789] LitePullConsumer supports manually adding subscription …
qianye1001 Nov 20, 2025
5892de6
[ISSUE #9862] [Bug] Fix the issue of missing bornTime in POP requests…
dingshuangxi888 Nov 20, 2025
736f027
[ISSUE #9870] Ensure metadata provider cache executors are shutdown c…
majialoong Nov 24, 2025
12774c6
[ISSUE #9779] fix DirectBuffer will cause error at 9+ JDK version. (#…
sinberCS Nov 24, 2025
f33f626
[ISSUE #9663] Add flatten-maven-plugin plugin (#9866)
lizhimins Nov 24, 2025
e984023
[ISSUE #9816] Fix calculate consumer lag with opentelemetry (#9873)
lizhimins Nov 25, 2025
e87f9cb
[ISSUE #9875] Optimize the RocksDB config shutdown logic when useSing…
RongtongJin Nov 26, 2025
b77f2ab
[ISSUE #9734] Prepare to release Apache RocketMQ 5.3.4 (#9861)
lizhimins Nov 26, 2025
63d20eb
[ISSUE #9734] Set revision to 5.3.4 in maven pom (#9876)
lizhimins Nov 27, 2025
bca6393
[ISSUE #9891] Optimize pop orderly implementation to facilitate expan…
qianye1001 Dec 2, 2025
9f58198
[ISSUE #9883] Remove unnecessary MessageFormat.format (#9884)
yx9o Dec 3, 2025
1a3c922
Defer the shutdown behavior of popConsumerService to prevent JVM cras…
RongtongJin Dec 3, 2025
47c6e89
[ISSUE #9894] Update README for RocketMQ 5.3.4 and minor fixes (#9895)
majialoong Dec 4, 2025
d7e27d6
[ISSUE #9396] Use fastjson2 in all modules (#9397)
yx9o Dec 4, 2025
cbfd37b
Add some log for gRPC route (#9896)
qianye1001 Dec 5, 2025
1bb2168
Fix controller mode HAService removeConnection (#9897)
LittleBoy18 Dec 5, 2025
89e021e
[ISSUE #9898] Remove AbstractBrokerRunnable and replace with Runnable
RongtongJin Dec 5, 2025
1f387b2
Fix ACL 2.0: correct consumer group extraction from retry topic in SE…
dingshuangxi888 Dec 10, 2025
f73fe6c
[ISSUE #9885] Fix tiered store cache count and bytes metrics (#9886)
majialoong Dec 11, 2025
7a08b4c
[RIP-82] Implement Timer message, transaction message, and index base…
zk-drizzle Dec 11, 2025
6f5b551
[ISSUE #9918] Fix the message may be renewed once more if the gRPC pu…
qianye1001 Dec 12, 2025
15796e7
[ISSUE #9912] Fix consumer offset timestamp displayed incorrect in ti…
woaishixiaoxiao Dec 12, 2025
beee84f
[ISSUE #9868] Fix getBrokerEpoch no response issue for empty paramete…
yx9o Dec 12, 2025
71659e3
[ISSUE #8903] fix dledger mode expired message can not delete on jdk9…
LittleBoy18 Dec 15, 2025
9f9cab8
[ISSUE #9396] replace fastjson with fastjson2 (#9927)
yuz10 Dec 16, 2025
bdae09d
[RIP-80] #9928 Implementation of Priority Message (#9929)
imzs Dec 18, 2025
8c7bf52
[ISSUE #9902] Remove unnecessary String.format (#9903)
yx9o Dec 18, 2025
6fa05ff
[ISSUE #9921] Limit the concurrency of Pop revive (#9922)
lizhimins Dec 18, 2025
c1ccc3c
[ISSUE #9914] Simplify isolation logic when updating fault item in se…
yx9o Dec 18, 2025
0792474
[ISSUE #9928] Add Priority IT for GRPC protocol
imzs Dec 19, 2025
02412eb
[ISSUE #9933] Fix the failure when RocksDBConfigToJsonCommand exports…
RongtongJin Dec 19, 2025
fe5c17c
Optimized the function naming (#9935)
zk-drizzle Dec 19, 2025
684e733
[ISSUE #9938] Rename misnamed Messing classes to Messaging (#9939)
yx9o Dec 23, 2025
fef690c
[ISSUE #9943] Remove redundant containsKey check in checkBrokerConfig…
yx9o Dec 24, 2025
5132258
Fix epoch truncate (#9942)
LittleBoy18 Dec 24, 2025
79e7003
[ISSUE #9945] Use UniqueKey as TimerDelKey by default
imzs Dec 24, 2025
541fdad
[ISSUE #9947] Fix TimerMessageStore.checkAndReviseMetrics throws Buff…
gaoyf Dec 24, 2025
4b187c6
[ISSUE #9945] Use UniqueKey as the TimerDelKey value when no namespac…
imzs Dec 24, 2025
b5da00a
[ISSUE #9936] Release Apache RocketMQ 5.4.0 (#9937)
lizhimins Dec 24, 2025
1117ab8
[ISSUE #9780] Skip unnecessary RPC when topic has no message queues (…
yx9o Dec 30, 2025
7cc0774
[ISSUE #9964] Rename intConfig method to initConfig (#9965)
yx9o Jan 4, 2026
cbe72c7
[ISSUE #9962] Fix the failure of fastjson2 parsing metricsExporterTyp…
yuz10 Jan 6, 2026
6ab57ad
[ISSUE #9976] Update copyright year in NOTICE file to 2026 (#9977)
mxsm Jan 6, 2026
9f23894
[ISSUE #9980] Skip invalid records when the group is absent in Pop (#…
lizhimins Jan 7, 2026
7fc5452
[ISSUE #9970] Refactor the MessageQueueSelector to support more flexi…
qianye1001 Jan 7, 2026
4c66580
[ISSUE #9994] Improve switchTimerEngine command with OptionGroup vali…
majialoong Jan 8, 2026
ae69814
[ISSUE #9923] Transactional messages should not send custom delayed m…
yx9o Jan 8, 2026
9fecafe
[ISSUE #9953] Fix: there's no need to decompress message body in serv…
humkum Jan 12, 2026
4eead13
[ISSUE #9912] Reduce excessive requests for consumer offset timestamp…
lizhimins Jan 13, 2026
b6cc188
[ISSUE #9992] Fix remoting server netty server codec thread reuse pro…
ymwneu Jan 14, 2026
500c468
[ISSUE #9978] Remove static from loadJsonConfig and unify exception s…
yx9o Jan 14, 2026
527bb98
[ISSUE #9900] Supports sending heartbeats to the broker concurrently …
Kris20030907 Jan 14, 2026
3d3a2d0
[ISSUE #9975] Bump broker rocksdb from 1.0.2 to 1.0.6 (#10002)
lizhimins Jan 14, 2026
45fc4e0
[ISSUE #10005] Fix switch-case logic in updateConsumerOffsetAsync (#1…
yx9o Jan 15, 2026
1b6a919
[RIP-83] Lite Topic: A New Message Model (#9800)
f1amingo Jan 16, 2026
ee10411
[ISSUE #10015] Optimize writeWithoutMmap. add page alignment to avoid…
guyinyou Jan 16, 2026
2eb537c
[ISSUE #9980] Skip invalid Pop records when consumer group does not e…
Gautam-aman Jan 20, 2026
899a1b5
[ISSUE #10023] Remove duplicate shutdown and rejection handler calls …
Kris20030907 Jan 20, 2026
36adf12
[ISSUE #10017] Validate commitlog offset in recoverAbnormally to prev…
guyinyou Jan 20, 2026
94ba5e1
[ISSUE #10031] Add PreprocessHandler interface in AllocateMappedFileS…
guyinyou Jan 21, 2026
4aa6cdd
[ISSUE #10019] Revert "[ISSUE #8127]Optimize the metric calculation l…
RongtongJin Jan 21, 2026
236ede2
Fix: avoid extra padding when message end position is already page-al…
guyinyou Jan 21, 2026
50e7ffa
[ISSUE #10040] Ignore flattened-pom.xml files generated by maven (#10…
yx9o Jan 22, 2026
90b0906
[ISSUE #10038] Fix checkCommitLogOffsetOnRecover to skip validation f…
guyinyou Jan 26, 2026
c7892a6
[ISSUE #9852] Print full message when CRC not found in properties (#…
guyinyou Jan 26, 2026
9ad4a1b
[ISSUE #9988] Remove mismatched response header in getConsumerConnect…
yx9o Jan 26, 2026
24ca9e4
[ISSUE #10043] Make TimerMessageReputService thread pool configurable…
Kris20030907 Jan 30, 2026
3a184c3
[ISSUE #10021] Optimize consumer type check with EnumSet (#10022)
yx9o Jan 30, 2026
89d331c
[ISSUE #10054] Correct the output format for ConsumerRecords (#10055)
yx9o Feb 2, 2026
7583fda
fix(store): close all consume queue file handles on ConsumeQueueStore…
RongtongJin Feb 2, 2026
f80753f
[ISSUE #10050] Support ChangeInvisibleTime without incrementing messa…
ltamber Feb 2, 2026
9388842
[ISSUE #9899] Forbid windows sync directory (#10057)
gaoyf Feb 2, 2026
10c650c
[ISSUE #10034] Optimizing cq iterator and calculating lag (#10056)
lizhimins Feb 2, 2026
0471136
[ISSUE #9999] Mark custom delay time messages with delay type (#10000)
yx9o Feb 5, 2026
a6c5604
[ISSUE #10046] Fix lock leak risk in sendHeartbeatToBroker (#10047)
yx9o Feb 5, 2026
7fe0349
[ISSUE #10063] Notification request adds subscription expression to s…
qianye1001 Feb 5, 2026
c2c674d
[ISSUE #10068] Remove duplicate registration in DefaultMessagingProce…
yx9o Feb 5, 2026
d254f79
[ISSUE #10071] Fix PopLiteLongPollingService#cleanUnusedResource
f1amingo Feb 5, 2026
26480dd
[ISSUE #10073] Fix StoreCheckpoint logicsMsgTimestamp to reflect flus…
guyinyou Feb 5, 2026
1754cec
Restore the lost PR 3460 (#10067)
gaoyf Feb 6, 2026
c197e50
[ISSUE #10079] FlushConsumeQueueService: always flush store checkpoin…
guyinyou Feb 9, 2026
ec7db8d
[ISSUE #10082] Missing PROPERTY_TIMER_DELAY_MS property check in dela…
dingshuangxi888 Feb 10, 2026
35d69cb
[ISSUE #10095] Upgraded Commons Lang3 to remediate CVEs (#10096)
shub-est Feb 11, 2026
a6be1ee
[ISSUE # 10086] Fix timer engine switch to persist correct config key…
Liu-ZhenYu Feb 11, 2026
76cd389
[ISSUE #10093] Enhance delayed message type validation in batch send …
yx9o Feb 11, 2026
d650a2d
Bump commons-validator from 1.7 to 1.10.0 (#10070) (#10081)
Zjianru Feb 12, 2026
5bca8f0
Upgraded LZ4 and migrated to newer group id (#10092)
shub-est Feb 12, 2026
2c70ce6
Upgraded Bouncy Castle to remediate CVEs (#10102)
shub-est Feb 12, 2026
6df8246
Upgraded Netty to 4.1.130.Final to remediate CVEs (#10090)
shub-est Feb 13, 2026
b8f8856
[ISSUE #10105] Fix ClassCastException in getLocks() method (#10106)
yx9o Feb 23, 2026
7be7202
[ISSUE #10108] Broker startup fail in recover (#10109)
yuz10 Feb 24, 2026
bd1038a
[ISSUE #10110] Plain request process success and response fail when t…
yuz10 Feb 24, 2026
330dccc
[ISSUE #10107] Fix fastjson2 integer overflow when parsing AtomicLong…
yx9o Feb 25, 2026
7030c45
[ISSUE #10061]Optimize the issue/pull request template of RocketMQ (#…
mxsm Feb 27, 2026
628230d
[ISSUE #10011] Optimize accelerated recovery process and refactor cod…
RongtongJin Feb 28, 2026
4c9f7a9
[ISSUE #10159] Fix unstable tests in DefaultMQLitePullConsumerWithTra…
yx9o Mar 13, 2026
4a29b7e
[ISSUE #10077] Support password-encrypted private keys for Proxy TLS …
majialoong Mar 13, 2026
70834e3
[ISSUE #10009] Convert internal-only public classes to inner classes …
sinberCS Mar 13, 2026
7742b7c
[ISSUE #10157] Fix tiered metadata leak after topic delete (#10158)
woaishixiaoxiao Mar 17, 2026
7c10c77
[ISSUE #10154] Rename BrokerConsumeStatsSubCommad to BrokerConsumeSta…
yx9o Mar 17, 2026
34648ed
[ISSUE #10161] reduce bytes copy in json encode(#10162)
ChineseTony Mar 17, 2026
2bc1783
[ISSUE #10168] Fix GetAllTopicConfigResponseHeader compatibility issu…
gaoyf Mar 17, 2026
ebf1595
[ISSUE #10103] Improve batch polling efficiency in pollIndexRecord me…
yx9o Mar 17, 2026
aea4177
[ISSUE #10171] Support custom JAVA_HOME on Linux in runbroker.sh and …
majialoong Mar 21, 2026
e100743
[ISSUE #10181] Some minor fixes in PopConsumerService (#10182)
lizhimins Mar 23, 2026
8d451f3
[ISSUE #10195] Ensure RocksDB compatibility in slave-master synchroni…
gaoyf Mar 24, 2026
59033a3
[ISSUE #10199] Fix stale write timestamp leads to duplicate transacti…
lizhimins Mar 25, 2026
932588d
[ISSUE #10201] Optimize queryOffset method overloads in IndexService …
yx9o Mar 25, 2026
b14f926
Remove some workflows (#10220)
RongtongJin Mar 27, 2026
35c88e3
[ISSUE #10225] Add RejectedExecutionHandler support for ThreadPoolMon…
ltamber Mar 30, 2026
103b7bc
[ISSUE #10229] Fix server-side reset offset does not take effect for …
qianye1001 Mar 30, 2026
e5d3372
[ISSUE #10223] Not query the index of system topics in tiered storage…
lizhimins Mar 30, 2026
7d7eb73
[ISSUE #10003] Add gRPC maxConcurrentCallsPerConnection Configuration…
qianye1001 Mar 30, 2026
d66cfa9
[ISSUE #10165] Prevent RocksDB metrics from being overwritten after t…
3424672656 Mar 30, 2026
3b12a25
[ISSUE #10076] Make orderly resetOffset wait on consume lock while pr…
LystranG Mar 31, 2026
459d27b
[ISSUE #10191] Fix wrong option value for namesrvAddr parsing in time…
majialoong Mar 31, 2026
9c0cc51
[ISSUE #10189] Remove unused fetchRemoteConfigExecutorService in MQCl…
Kris20030907 Mar 31, 2026
d68d5a5
[ISSUE #10183] Fix incorrect brokerName when constructing ProcessQueu…
Kris20030907 Apr 2, 2026
860de80
[ISSUE #10183] Fix incorrect brokerName when constructing processQueu…
Kris20030907 Apr 3, 2026
614b816
[ISSUE #10203] Support wildcard subscription and and consumer suspend…
f1amingo Apr 3, 2026
2c2cc92
[ISSUE #10173] Support LMQ in CombineConsumeQueueStore without migrat…
imzs Apr 3, 2026
7b85a5d
[ISSUE #10240] Add BatchSplittingMetricExporter to prevent OTLP gRPC …
Houlong66 Apr 3, 2026
343daa9
[ISSUE #10173] Improve PopLite: rename RocksDB CQ path and schedule a…
imzs Apr 7, 2026
2b5e709
[ISSUE #9777 ]feat: use data version from master while sync slave and…
absolute8511 Apr 9, 2026
b8aba3b
[ISSUE #10181] Remove lock when resetting offset in PopConsumerServic…
lizhimins Apr 10, 2026
9879968
[ISSUE #10238] Release Apache RocketMQ 5.5.0 (#10251)
lizhimins Apr 10, 2026
840b18c
[ISSUE #10260] Reject delayed transactional messages in gRPC send pat…
yx9o Apr 21, 2026
94fbfcf
[ISSUE #10268] Fix incorrect time range file selection in IndexStoreS…
lizhimins Apr 21, 2026
f04eafc
[ISSUE #10266] Fix OOM caused by OpenTelemetry 1.44 OtlpGrpcMetricExp…
Houlong66 Apr 21, 2026
0752ddf
[ISSUE #10270] Make Pop RocksDB BlockCache size configurable via Mess…
lizhimins Apr 22, 2026
c083052
[ISSUE #10253] Fix stale wildcardGroupMap entries caused by incorrect…
Kris20030907 Apr 23, 2026
5ad6a3e
[ISSUE #10274] Fix ForwardMessageToDeadLetterQueue request mapping de…
Kris20030907 Apr 28, 2026
c6fc39a
[ISSUE #10276] Fix PopConsumerService changeInvisibilityDuration losi…
qianye1001 May 6, 2026
bd903d5
[ISSUE #10284] Fix consumerOffset deserialization error and add test …
ChineseTony May 12, 2026
c5a4da5
[ISSUE #10297] Set brokerName for messages returned by proxy local PO…
yx9o May 13, 2026
c625406
[ISSUE #10291] fix queryMessage default index type (#10292)
yuz10 May 15, 2026
17b4e56
[ISSUE #10285] Fix preserve popTime when rebuilding AckResult (#10286)
yx9o May 18, 2026
a3abd51
[ISSUE #10341] Fix Bazel CI build failure caused by Maven Central rat…
lizhimins May 19, 2026
61c493c
[ISSUE #10334] Support native CqCompactionFilter with cross-platform …
lizhimins May 21, 2026
079038d
[ISSUE #10247] Remove duplicate remove call in InvocationChannel (#10…
yx9o May 21, 2026
54708be
[DOCS] Update example dependency version from 4.3.0 to 5.5.0 (#10349)
H145608 May 22, 2026
1251c9a
[ISSUE #10280] Restore opaque when proxy remoting forward fails (#10281)
yx9o May 23, 2026
7e5d22d
[ISSUE #10334] Make native CqCompactionFilter shim self-contained wit…
lizhimins May 25, 2026
eb95ba3
[DOCS] Fix typo in Troubleshooting.md filename (#10360)
H145608 May 25, 2026
980f3d7
[ISSUE #10373] Quarantine flaky tests and add detection plan docs (#1…
lizhimins May 25, 2026
9e2d877
[ISSUE #10375] Fix race condition between deleteTopic and FlushConsum…
f1amingo May 25, 2026
b268d06
[ISSUE #10373] Fix quarantined flaky tests and remove CI rerun workflow
lizhimins May 26, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
15 changes: 12 additions & 3 deletions .asf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -23,13 +23,14 @@ github:
- cloud-native
- rocketmq
- java
- hacktoberfest
enabled_merge_buttons:
# Enable squash button
squash: true
# Disable merge button
merge: false
# Enable rebase button
rebase: true
# Disable rebase button
rebase: false
protected_branches:
master: {}
develop:
Expand All @@ -41,4 +42,12 @@ github:
contexts:
- misspell-check
- check-license
- maven-compile (ubuntu-18.04, JDK-8)
- maven-compile (ubuntu-latest, JDK-8)
- maven-compile (windows-latest, JDK-8)
- maven-compile (macos-latest, JDK-8)
notifications:
commits: commits@rocketmq.apache.org
issues: commits@rocketmq.apache.org
pullrequests: commits@rocketmq.apache.org
jobs: commits@rocketmq.apache.org
discussions: dev@rocketmq.apache.org
36 changes: 15 additions & 21 deletions .bazelrc
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,11 @@ build --enable_platform_specific_config
test --action_env=TEST_TMPDIR=/tmp

test --experimental_strict_java_deps=warn
test --experimental_ui_max_stdouterr_bytes=10485760
build --experimental_strict_java_deps=warn

test --test_output=errors


# This .bazelrc file contains all of the flags required for the provided
# toolchain with Remote Build Execution.
Expand All @@ -38,27 +41,14 @@ build --experimental_strict_java_deps=warn
# for a remote machine to execute them.
build:remote --jobs=150

# Set several flags related to specifying the platform, toolchain and java
# properties.
# These flags should only be used as is for the rbe-ubuntu16-04 container
# and need to be adapted to work with other toolchain containers.
build:remote --java_runtime_version=rbe_jdk
build:remote --tool_java_runtime_version=rbe_jdk
build:remote --extra_toolchains=@rbe_default//java:all

build:remote --crosstool_top=@rbe_default//cc:toolchain
build:remote --action_env=BAZEL_DO_NOT_DETECT_CPP_TOOLCHAIN=1
# Platform flags:
# The toolchain container used for execution is defined in the target indicated
# by "extra_execution_platforms", "host_platform" and "platforms".
# More about platforms: https://docs.bazel.build/versions/master/platforms.html
build:remote --extra_toolchains=@rbe_default//config:cc-toolchain
build:remote --extra_execution_platforms=@rbe_default//config:platform
build:remote --host_platform=@rbe_default//config:platform
build:remote --platforms=@rbe_default//config:platform

# Starting with Bazel 0.27.0 strategies do not need to be explicitly
# defined. See https://github.com/bazelbuild/bazel/issues/7480
build:remote --remote_executor=grpcs://remote.buildbuddy.io
build:remote --host_platform=@buildbuddy_toolchain//:platform
build:remote --platforms=@buildbuddy_toolchain//:platform
build:remote --extra_execution_platforms=@buildbuddy_toolchain//:platform
build:remote --crosstool_top=@buildbuddy_toolchain//:toolchain
build:remote --extra_toolchains=@buildbuddy_toolchain//:cc_toolchain
build:remote --java_language_version=8
build:remote --java_runtime_version=8
build:remote --define=EXECUTOR=remote

# Enable remote execution so actions are performed on the remote systems.
Expand All @@ -71,3 +61,7 @@ build:remote --incompatible_strict_action_env=true

# Set a higher timeout value, just in case.
build:remote --remote_timeout=3600

# Use a pre-configured account, such that we may have pull-request replacing pull-request-target
build:remote --remote_header=x-buildbuddy-api-key=FD819nUEY7WjvqmoufsU
test:remote --remote_header=x-buildbuddy-api-key=FD819nUEY7WjvqmoufsU
2 changes: 1 addition & 1 deletion .bazelversion
Original file line number Diff line number Diff line change
@@ -1 +1 @@
5.2.0
6.5.0
112 changes: 112 additions & 0 deletions .github/ISSUE_TEMPLATE/bug_report.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,112 @@
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

name: Bug Report
title: "[Bug] Bug title "
description: Create a report to help us identify any unintended flaws, errors, or faults.
body:
- type: checkboxes
attributes:
label: Before Creating the Bug Report
options:
- label: >
I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq/discussions).
required: true
- label: >
I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/discussions) of this repository and believe that this is not a duplicate.
required: true
- label: >
I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.
required: true

- type: textarea
attributes:
label: Runtime platform environment
description: Describe the runtime platform environment.
placeholder: >
OS: (e.g., "Ubuntu 20.04")
OS: (e.g., "Windows Server 2019")
validations:
required: true

- type: textarea
attributes:
label: RocketMQ version
description: Describe the RocketMQ version.
placeholder: >
branch: (e.g develop|4.9.x)
version: (e.g. 5.1.0|4.9.5)
Git commit id: (e.g. c88b5cfa72e204962929eea105687647146112c6)
validations:
required: true

- type: textarea
attributes:
label: JDK Version
description: Run or Compiler version.
placeholder: >
Compiler: (e.g., "Oracle JDK 11.0.17")
OS: (e.g., "Ubuntu 20.04")
Runtime (if different from JDK above): (e.g., "Oracle JRE 8u251")
OS (if different from OS compiled on): (e.g., "Windows Server 2019")
validations:
required: false

- type: textarea
attributes:
label: Describe the Bug
description: Describe what happened.
placeholder: >
A clear and concise description of what the bug is.
validations:
required: true

- type: textarea
attributes:
label: Steps to Reproduce
description: Describe the steps to reproduce the bug here.
placeholder: >
If possible, provide a recipe for reproducing the error.
validations:
required: true

- type: textarea
attributes:
label: What Did You Expect to See?
description: You expect to see result.
placeholder: >
A clear and concise description of what you expected to see.
validations:
required: true

- type: textarea
attributes:
label: What Did You See Instead?
description: You instead to see result.
placeholder: >
A clear and concise description of what you saw instead.
validations:
required: true

- type: textarea
attributes:
label: Additional Context
description: Additional context.
placeholder: >
Add any other context about the problem here.
validations:
required: false
23 changes: 23 additions & 0 deletions .github/ISSUE_TEMPLATE/config.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#


blank_issues_enabled: false
contact_links:
- name: Ask Question
url: https://github.com/apache/rocketmq/discussions
about: Please go to GitHub Disccusions to ask questions
55 changes: 55 additions & 0 deletions .github/ISSUE_TEMPLATE/doc.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,55 @@
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

name: Documentation Related
title: "[Doc] Documentation Related "
description: I find some issues related to the documentation.
labels: [ "module/doc" ]
body:
- type: checkboxes
attributes:
label: Search before creation
description: >
Please make sure to search in the [issues](https://github.com/apache/rocketmq/issues)
first to see whether the same issue was reported already.
options:
- label: >
I had searched in the [issues](https://github.com/apache/rocketmq/issues) and found
no similar issues.
required: true

- type: textarea
attributes:
label: Documentation Related
description: Describe the suggestion about document.
placeholder: >
e.g There is a typo
validations:
required: true

- type: checkboxes
attributes:
label: Are you willing to submit PR?
description: >
This is absolutely not required, but we are happy to guide you in the contribution process
especially if you already have a good understanding of how to implement the fix.
options:
- label: Yes I am willing to submit a PR!

- type: markdown
attributes:
value: "Thanks for completing our form!"
75 changes: 75 additions & 0 deletions .github/ISSUE_TEMPLATE/enhancement_request.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,75 @@
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#


name: Enhancement Request
title: "[Enhancement] Enhancement title"
description: Suggest an enhancement for this project
labels: [ "type/enhancement" ]
body:
- type: checkboxes
attributes:
label: Before Creating the Enhancement Request
description: >
Most of issues should be classified as bug or feature request. An issue should be considered as an enhancement when it proposes improvements to
existing functionality or user experience, without necessarily introducing new features or fixing existing bugs.
options:
- label: >
I have confirmed that this should be classified as an enhancement rather than a bug/feature.
required: true

- type: textarea
attributes:
label: Summary
placeholder: >
A clear and concise description of the enhancement you would like to see in the project.
validations:
required: true

- type: textarea
attributes:
label: Motivation
placeholder: >
Explain why you believe this enhancement is necessary, and how it benefits the project and community.
Include any specific use cases that you have in mind.
validations:
required: true

- type: textarea
attributes:
label: Describe the Solution You'd Like
placeholder: >
Describe the enhancement you propose, detailing the change and implementation steps involved.
If you have multiple solutions, please list them separately.
validations:
required: true

- type: textarea
attributes:
label: Describe Alternatives You've Considered
placeholder: >
List any alternative enhancements or implementations you have considered, and explain why they may not be as effective or appropriate.
validations:
required: true

- type: textarea
attributes:
label: Additional Context
placeholder: >
Add any relevant context, screenshots, prototypes, or other supplementary information to help illustrate the enhancement.
validations:
required: false
Loading
Loading