Sign in
apache
/
rocketmq
/
HEAD
10c650c
[ISSUE #10034] Optimizing cq iterator and calculating lag (#10056)
by lizhimins
· 25 hours ago
develop
9388842
[ISSUE #9899] Forbid windows sync directory (#10057)
by gaoyf
· 31 hours ago
f80753f
[ISSUE #10050] Support ChangeInvisibleTime without incrementing message reconsume times (#10051)
by ltamber
· 32 hours ago
7583fda
fix(store): close all consume queue file handles on ConsumeQueueStore shutdown (#10060)
by rongtong
· 35 hours ago
89d331c
[ISSUE #10054] Correct the output format for ConsumerRecords (#10055)
by yx9o
· 35 hours ago
3a184c3
[ISSUE #10021] Optimize consumer type check with EnumSet (#10022)
by yx9o
· 5 days ago
24ca9e4
[ISSUE #10043] Make TimerMessageReputService thread pool configurable and shutdown gracefully (#10044)
by wizcraft_kris
· 5 days ago
9ad4a1b
[ISSUE #9988] Remove mismatched response header in getConsumerConnectionList (#9989)
by yx9o
· 8 days ago
c7892a6
[ISSUE #9852] Print full message when CRC not found in properties (#9853)
by guyinyou
· 9 days ago
90b0906
[ISSUE #10038] Fix checkCommitLogOffsetOnRecover to skip validation for BLANK_MAGIC_CODE messages (#10039)
by guyinyou
· 9 days ago
50e7ffa
[ISSUE #10040] Ignore flattened-pom.xml files generated by maven (#10041)
by yx9o
· 12 days ago
236ede2
Fix: avoid extra padding when message end position is already page-aligned (#10036)
by guyinyou
· 13 days ago
4aa6cdd
[ISSUE #10019] Revert "[ISSUE #8127]Optimize the metric calculation logic of the time wheel" (#10020)
by rongtong
· 13 days ago
94ba5e1
[ISSUE #10031] Add PreprocessHandler interface in AllocateMappedFileService
by guyinyou
· 14 days ago
36adf12
[ISSUE #10017] Validate commitlog offset in recoverAbnormally to prevent processing … (#10018)
by guyinyou
· 2 weeks ago
899a1b5
[ISSUE #10023] Remove duplicate shutdown and rejection handler calls for routeThreadPoolExecutor (#10024)
by wizcraft_kris
· 2 weeks ago
2eb537c
[ISSUE #9980] Skip invalid Pop records when consumer group does not exist (#9982)
by Aman Gautam
· 2 weeks ago
ee10411
[ISSUE #10015] Optimize writeWithoutMmap. add page alignment to avoid read-modify-write
by guyinyou
· 3 weeks ago
1b6a919
[RIP-83] Lite Topic: A New Message Model (#9800)
by Quan
· 3 weeks ago
45fc4e0
[ISSUE #10005] Fix switch-case logic in updateConsumerOffsetAsync (#10006)
by yx9o
· 3 weeks ago
3d3a2d0
[ISSUE #9975] Bump broker rocksdb from 1.0.2 to 1.0.6 (#10002)
by lizhimins
· 3 weeks ago
527bb98
[ISSUE #9900] Supports sending heartbeats to the broker concurrently (#9901)
by wizcraft_kris
· 3 weeks ago
500c468
[ISSUE #9978] Remove static from loadJsonConfig and unify exception strings (#9979)
by yx9o
· 3 weeks ago
b6cc188
[ISSUE #9992] Fix remoting server netty server codec thread reuse problem (#9993)
by ymwneu
· 3 weeks ago
4eead13
[ISSUE #9912] Reduce excessive requests for consumer offset timestamps in tiered storage (#9991)
by lizhimins
· 3 weeks ago
9fecafe
[ISSUE #9953] Fix: there's no need to decompress message body in server side (#9954)
by Humkum
· 3 weeks ago
ae69814
[ISSUE #9923] Transactional messages should not send custom delayed messages (#9924)
by yx9o
· 4 weeks ago
4c66580
[ISSUE #9994] Improve switchTimerEngine command with OptionGroup validation (#9995)
by majialong
· 4 weeks ago
7fc5452
[ISSUE #9970] Refactor the MessageQueueSelector to support more flexible queue selection strategy (#9971)
by qianye
· 4 weeks ago
9f23894
[ISSUE #9980] Skip invalid records when the group is absent in Pop (#9981)
by lizhimins
· 4 weeks ago
6ab57ad
[ISSUE #9976] Update copyright year in NOTICE file to 2026 (#9977)
by mxsm
· 4 weeks ago
cbe72c7
[ISSUE #9962] Fix the failure of fastjson2 parsing metricsExporterType in proxy config (#9963)
by yuz10
· 4 weeks ago
7cc0774
[ISSUE #9964] Rename intConfig method to initConfig (#9965)
by yx9o
· 4 weeks ago
1117ab8
[ISSUE #9780] Skip unnecessary RPC when topic has no message queues (#9781)
by yx9o
· 5 weeks ago
b5da00a
[ISSUE #9936] Release Apache RocketMQ 5.4.0 (#9937)
by lizhimins
· 6 weeks ago
release-5.4.0
rocketmq-all-5.4.0
4b187c6
[ISSUE #9945] Use UniqueKey as the TimerDelKey value when no namespace is appended (#9951)
by imzs
· 6 weeks ago
541fdad
[ISSUE #9947] Fix TimerMessageStore.checkAndReviseMetrics throws BufferUnderflowException (#9948)
by gaoyf
· 6 weeks ago
79e7003
[ISSUE #9945] Use UniqueKey as TimerDelKey by default
by imzs
· 6 weeks ago
5132258
Fix epoch truncate (#9942)
by littleboy
· 6 weeks ago
fef690c
[ISSUE #9943] Remove redundant containsKey check in checkBrokerConfig (#9944)
by yx9o
· 6 weeks ago
684e733
[ISSUE #9938] Rename misnamed Messing classes to Messaging (#9939)
by yx9o
· 6 weeks ago
fe5c17c
Optimized the function naming (#9935)
by Drizzle
· 7 weeks ago
02412eb
[ISSUE #9933] Fix the failure when RocksDBConfigToJsonCommand exports locally. (#9934)
by rongtong
· 7 weeks ago
0792474
[ISSUE #9928] Add Priority IT for GRPC protocol
by imzs
· 7 weeks ago
c1ccc3c
[ISSUE #9914] Simplify isolation logic when updating fault item in sendKernelImpl (#9915)
by yx9o
· 7 weeks ago
6fa05ff
[ISSUE #9921] Limit the concurrency of Pop revive (#9922)
by lizhimins
· 7 weeks ago
8c7bf52
[ISSUE #9902] Remove unnecessary String.format (#9903)
by yx9o
· 7 weeks ago
bdae09d
[RIP-80] #9928 Implementation of Priority Message (#9929)
by imzs
· 7 weeks ago
9f9cab8
[ISSUE #9396] replace fastjson with fastjson2 (#9927)
by yuz10
· 7 weeks ago
71659e3
[ISSUE #8903] fix dledger mode expired message can not delete on jdk9+ (#9851)
by littleboy
· 7 weeks ago
beee84f
[ISSUE #9868] Fix getBrokerEpoch no response issue for empty parameters (#9869)
by yx9o
· 8 weeks ago
15796e7
[ISSUE #9912] Fix consumer offset timestamp displayed incorrect in tiered store (#9913)
by SHI
· 8 weeks ago
6f5b551
[ISSUE #9918] Fix the message may be renewed once more if the gRPC push consumer is unexpectedly disconnected (#9919)
by qianye
· 8 weeks ago
7a08b4c
[RIP-82] Implement Timer message, transaction message, and index based on RocksDB (#9787)
by Drizzle
· 8 weeks ago
f73fe6c
[ISSUE #9885] Fix tiered store cache count and bytes metrics (#9886)
by majialong
· 8 weeks ago
1f387b2
Fix ACL 2.0: correct consumer group extraction from retry topic in SEND_MESSAGE/SEND_MESSAGE_V2/SEND_BATCH_MESSAGE (#9911)
by dingshuangxi888
· 8 weeks ago
89e021e
[ISSUE #9898] Remove AbstractBrokerRunnable and replace with Runnable
by rongtong
· 9 weeks ago
1bb2168
Fix controller mode HAService removeConnection (#9897)
by littleboy
· 9 weeks ago
cbfd37b
Add some log for gRPC route (#9896)
by qianye
· 9 weeks ago
d7e27d6
[ISSUE #9396] Use fastjson2 in all modules (#9397)
by yx9o
· 9 weeks ago
47c6e89
[ISSUE #9894] Update README for RocketMQ 5.3.4 and minor fixes (#9895)
by majialong
· 9 weeks ago
1a3c922
Defer the shutdown behavior of popConsumerService to prevent JVM crash (#9889)
by rongtong
· 9 weeks ago
9f58198
[ISSUE #9883] Remove unnecessary MessageFormat.format (#9884)
by yx9o
· 9 weeks ago
bca6393
[ISSUE #9891] Optimize pop orderly implementation to facilitate expansion (#9892)
by qianye
· 9 weeks ago
63d20eb
[ISSUE #9734] Set revision to 5.3.4 in maven pom (#9876)
by lizhimins
· 10 weeks ago
release-5.3.4
rocketmq-all-5.3.4
b77f2ab
[ISSUE #9734] Prepare to release Apache RocketMQ 5.3.4 (#9861)
by lizhimins
· 10 weeks ago
e87f9cb
[ISSUE #9875] Optimize the RocksDB config shutdown logic when useSingleRocksDBForAllConfigs is set to true to prevent JVM crashes. (#9874)
by rongtong
· 10 weeks ago
e984023
[ISSUE #9816] Fix calculate consumer lag with opentelemetry (#9873)
by lizhimins
· 2 months ago
f33f626
[ISSUE #9663] Add flatten-maven-plugin plugin (#9866)
by lizhimins
· 2 months ago
12774c6
[ISSUE #9779] fix DirectBuffer will cause error at 9+ JDK version. (#9801)
by sinberCS
· 2 months ago
736f027
[ISSUE #9870] Ensure metadata provider cache executors are shutdown correctly (#9871)
by majialong
· 2 months ago
5892de6
[ISSUE #9862] [Bug] Fix the issue of missing bornTime in POP requests when broker ACL is enabled (#9863)
by dingshuangxi888
· 3 months ago
ccf9730
[ISSUE #9789] LitePullConsumer supports manually adding subscription reported in Heartbeat (#9790)
by qianye
· 3 months ago
a68a5bf
[ISSUE #9809] Fix NPE in getAcl when subject is null (#9810)
by majialong
· 3 months ago
963c0e2
[ISSUE #9741] Optimize authorization whitelist lookup efficiency (#9760)
by majialong
· 3 months ago
8eabe68
[ISSUE #9849] Correct ACL cache loader error log in ClusterMetadataService (#9850)
by majialong
· 3 months ago
7acfe4d
[ISSUE #9737] Fix client memory leak on connection failure (#9740)
by qianye
· 3 months ago
d08f787
[ISSUE #9807] Optimize log.warn Time Consumption in the send Method (#9808)
by yx9o
· 3 months ago
d750461
[ISSUE #9857] Optimize the performance of the notification by removing unnecessary retry checks (#9858)
by qianye
· 3 months ago
9c3e7fe
[ISSUE #9847] Reduce lock contention on the HandleData object to prevent threads from hanging (#9848)
by qianye
· 3 months ago
6c798d6
[ISSUE #9593] Optimize Deflater resource release (#9594)
by yx9o
· 3 months ago
69e2524
Fix resource leak in IndexStoreFile shutdown (#9840)
by rongtong
· 3 months ago
2017630
[ISSUE #9834] Support writeWithoutMmap in IndexStoreFile (#9835)
by rongtong
· 3 months ago
e60b67a
[ISSUE #9838] IndexStoreService use forceShutdown when disk is not writable (#9839)
by rongtong
· 3 months ago
3b78ab0
[ISSUE #9632] Fix Pop Long-polling Not Awakened for V1 Retry Messages (#9828)
by qianye
· 3 months ago
7a1a950
[ISSUE# 9841] Improve Resource Management in TimerWheel to Prevent File Handle Leaks (#9842)
by guyinyou
· 3 months ago
e2be0f2
fix controller mode scanControllerAddress (#9845)
by littleboy
· 3 months ago
f0d3b9c
[ISSUE #9794] Change JDK prerequisite from 1.7+ to 1.8+ in documentation (#9795)
by yx9o
· 3 months ago
12f8db1
[ISSUE #9821] Fix getBrokerConfig no response issue for empty parameters (#9822)
by yx9o
· 3 months ago
e4170f5
Add timestamp query message offset to abstract class (#9836)
by lizhimins
· 3 months ago
29a62c4
[ISSUE #9735] Add TimerWheel snapshot mechanism for reliable recovery (#9736)
by guyinyou
· 3 months ago
607263b
upgrade OpenTelemetry to version 1.44.1 (#9820)
by rongtong
· 3 months ago
35a7474
[ISSUE #9802] Fix the issue of delete logic in tiered storage index service (#9803)
by lizhimins
· 3 months ago
e7d930f
Fixed error message of CommandUtil.fetchMasterAddrByBrokerName (#9825)
by Michael Hausegger
· 3 months ago
455305a
[ISSUE #9813] Fix buffer fetch thread pool starvation in tiered storage (#9818)
by lizhimins
· 3 months ago
736d2a8
[ISSUE #9816] Fix concurrent modify opentelemetry record in calculate consumer lag (#9817)
by lizhimins
· 3 months ago
440341b
[ISSUE #9811] Fixed the issue of excessive loop iterations in reput service (#9812)
by lizhimins
· 3 months ago
6b91c7d
[ISSUE #9798] Reduce unnecessary thread switching in sending message via proxy (#9799)
by qianye
· 3 months ago
d7c8bb7
[ISSUE #9784] Fix the policy comparator to prioritize DENY over ALLOW (#9785)
by majialong
· 3 months ago
204b251
Correct method name from updateDateVersion to updateDataVersion (#9788)
by majialong
· 3 months ago
Next »