Sign in
apache
/
rocketmq
/
HEAD
c6fc39a
[ISSUE #10276] Fix PopConsumerService changeInvisibilityDuration losing CK record when visibilityTimeout collision (#10277)
by qianye
· 32 hours ago
apache-develop
develop
5ad6a3e
[ISSUE #10274] Fix ForwardMessageToDeadLetterQueue request mapping descriptor (#10275)
by wizcraft_kris
· 9 days ago
c083052
[ISSUE #10253] Fix stale wildcardGroupMap entries caused by incorrect parsing during LiteTopic wildcard unregistration (#10254)
by wizcraft_kris
· 2 weeks ago
0752ddf
[ISSUE #10270] Make Pop RocksDB BlockCache size configurable via MessageStoreConfig (#10271)
by lizhimins
· 2 weeks ago
f04eafc
[ISSUE #10266] Fix OOM caused by OpenTelemetry 1.44 OtlpGrpcMetricExporter pool race (#10267)
by Houlong66
· 2 weeks ago
94fbfcf
[ISSUE #10268] Fix incorrect time range file selection in IndexStoreService.queryAsync (#10269)
by lizhimins
· 2 weeks ago
840b18c
[ISSUE #10260] Reject delayed transactional messages in gRPC send path (#10261)
by yx9o
· 2 weeks ago
9879968
[ISSUE #10238] Release Apache RocketMQ 5.5.0 (#10251)
by lizhimins
· 4 weeks ago
rocketmq-all-5.5.0
b8aba3b
[ISSUE #10181] Remove lock when resetting offset in PopConsumerService (#10250)
by lizhimins
· 4 weeks ago
2b5e709
[ISSUE #9777 ]feat: use data version from master while sync slave and fix delete co… (#9778)
by Vincent Lee
· 4 weeks ago
343daa9
[ISSUE #10173] Improve PopLite: rename RocksDB CQ path and schedule autoClean (#10242)
by imzs
· 4 weeks ago
7b85a5d
[ISSUE #10240] Add BatchSplittingMetricExporter to prevent OTLP gRPC export failures (#10239)
by Houlong66
· 5 weeks ago
2c2cc92
[ISSUE #10173] Support LMQ in CombineConsumeQueueStore without migration to RocksDB CQ (#10174)
by imzs
· 5 weeks ago
614b816
[ISSUE #10203] Support wildcard subscription and and consumer suspend for LiteTopic (#10204)
by Quan
· 5 weeks ago
860de80
[ISSUE #10183] Fix incorrect brokerName when constructing processQueueTable with static topic (#10186)
by wizcraft_kris
· 5 weeks ago
d68d5a5
[ISSUE #10183] Fix incorrect brokerName when constructing ProcessQueueTable with static topic (#10184)
by wizcraft_kris
· 5 weeks ago
9c0cc51
[ISSUE #10189] Remove unused fetchRemoteConfigExecutorService in MQClientInstance (#10190)
by wizcraft_kris
· 5 weeks ago
459d27b
[ISSUE #10191] Fix wrong option value for namesrvAddr parsing in timer benchmark examples (#10192)
by majialong
· 5 weeks ago
3b12a25
[ISSUE #10076] Make orderly resetOffset wait on consume lock while preserving timeout semantics (#10175)
by Lystran
· 5 weeks ago
d66cfa9
[ISSUE #10165] Prevent RocksDB metrics from being overwritten after timer engine switch (#10166)
by hqbfz
· 5 weeks ago
7d7eb73
[ISSUE #10003] Add gRPC maxConcurrentCallsPerConnection Configuration to Proxy (#10004)
by qianye
· 5 weeks ago
e5d3372
[ISSUE #10223] Not query the index of system topics in tiered storage (#10224)
by lizhimins
· 5 weeks ago
103b7bc
[ISSUE #10229] Fix server-side reset offset does not take effect for FIFO (orderly) pop consumers (#10230)
by qianye
· 5 weeks ago
35c88e3
[ISSUE #10225] Add RejectedExecutionHandler support for ThreadPoolMonitor (#10222)
by ltamber
· 5 weeks ago
b14f926
Remove some workflows (#10220)
by rongtong
· 6 weeks ago
932588d
[ISSUE #10201] Optimize queryOffset method overloads in IndexService (#10202)
by yx9o
· 6 weeks ago
59033a3
[ISSUE #10199] Fix stale write timestamp leads to duplicate transaction commit (#10200)
by lizhimins
· 6 weeks ago
8d451f3
[ISSUE #10195] Ensure RocksDB compatibility in slave-master synchronization (#10196)
by gaoyf
· 6 weeks ago
e100743
[ISSUE #10181] Some minor fixes in PopConsumerService (#10182)
by lizhimins
· 6 weeks ago
aea4177
[ISSUE #10171] Support custom JAVA_HOME on Linux in runbroker.sh and runserver.sh (#10172)
by majialong
· 7 weeks ago
ebf1595
[ISSUE #10103] Improve batch polling efficiency in pollIndexRecord method (#10104)
by yx9o
· 7 weeks ago
2bc1783
[ISSUE #10168] Fix GetAllTopicConfigResponseHeader compatibility issue (#10169)
by gaoyf
· 7 weeks ago
34648ed
[ISSUE #10161] reduce bytes copy in json encode(#10162)
by ChineseTony
· 7 weeks ago
7c10c77
[ISSUE #10154] Rename BrokerConsumeStatsSubCommad to BrokerConsumeStatsSubCommand (#10155)
by yx9o
· 7 weeks ago
7742b7c
[ISSUE #10157] Fix tiered metadata leak after topic delete (#10158)
by SHI
· 7 weeks ago
70834e3
[ISSUE #10009] Convert internal-only public classes to inner classes and add null-check log (#10028)
by sinberCS
· 8 weeks ago
4a29b7e
[ISSUE #10077] Support password-encrypted private keys for Proxy TLS (#10078)
by majialong
· 8 weeks ago
4c9f7a9
[ISSUE #10159] Fix unstable tests in DefaultMQLitePullConsumerWithTraceTest (#10160)
by yx9o
· 8 weeks ago
628230d
[ISSUE #10011] Optimize accelerated recovery process and refactor code (#10012)
by rongtong
· 10 weeks ago
7030c45
[ISSUE #10061]Optimize the issue/pull request template of RocketMQ (#10062)
by mxsm
· 10 weeks ago
330dccc
[ISSUE #10107] Fix fastjson2 integer overflow when parsing AtomicLong (#10112)
by yx9o
· 2 months ago
bd1038a
[ISSUE #10110] Plain request process success and response fail when tlsMode=enforcing (#10111)
by yuz10
· 2 months ago
7be7202
[ISSUE #10108] Broker startup fail in recover (#10109)
by yuz10
· 2 months ago
b8f8856
[ISSUE #10105] Fix ClassCastException in getLocks() method (#10106)
by yx9o
· 2 months ago
6df8246
Upgraded Netty to 4.1.130.Final to remediate CVEs (#10090)
by shub-est
· 3 months ago
2c70ce6
Upgraded Bouncy Castle to remediate CVEs (#10102)
by shub-est
· 3 months ago
5bca8f0
Upgraded LZ4 and migrated to newer group id (#10092)
by shub-est
· 3 months ago
d650a2d
Bump commons-validator from 1.7 to 1.10.0 (#10070) (#10081)
by codez
· 3 months ago
76cd389
[ISSUE #10093] Enhance delayed message type validation in batch send (#10094)
by yx9o
· 3 months ago
a6be1ee
[ISSUE # 10086] Fix timer engine switch to persist correct config key (#10085)
by liuzhenyu
· 3 months ago
35d69cb
[ISSUE #10095] Upgraded Commons Lang3 to remediate CVEs (#10096)
by shub-est
· 3 months ago
ec7db8d
[ISSUE #10082] Missing PROPERTY_TIMER_DELAY_MS property check in delay message type validation (#10084)
by dingshuangxi888
· 3 months ago
c197e50
[ISSUE #10079] FlushConsumeQueueService: always flush store checkpoint after CQ flush (#10080)
by guyinyou
· 3 months ago
1754cec
Restore the lost PR 3460 (#10067)
by gaoyf
· 3 months ago
26480dd
[ISSUE #10073] Fix StoreCheckpoint logicsMsgTimestamp to reflect flushed consume queue storetime (#10074)
by guyinyou
· 3 months ago
d254f79
[ISSUE #10071] Fix PopLiteLongPollingService#cleanUnusedResource
by Quan
· 3 months ago
c2c674d
[ISSUE #10068] Remove duplicate registration in DefaultMessagingProcessor.init (#10069)
by yx9o
· 3 months ago
7fe0349
[ISSUE #10063] Notification request adds subscription expression to support on-demand wake-up (#10064)
by qianye
· 3 months ago
a6c5604
[ISSUE #10046] Fix lock leak risk in sendHeartbeatToBroker (#10047)
by yx9o
· 3 months ago
0471136
[ISSUE #9999] Mark custom delay time messages with delay type (#10000)
by yx9o
· 3 months ago
10c650c
[ISSUE #10034] Optimizing cq iterator and calculating lag (#10056)
by lizhimins
· 3 months ago
9388842
[ISSUE #9899] Forbid windows sync directory (#10057)
by gaoyf
· 3 months ago
f80753f
[ISSUE #10050] Support ChangeInvisibleTime without incrementing message reconsume times (#10051)
by ltamber
· 3 months ago
7583fda
fix(store): close all consume queue file handles on ConsumeQueueStore shutdown (#10060)
by rongtong
· 3 months ago
89d331c
[ISSUE #10054] Correct the output format for ConsumerRecords (#10055)
by yx9o
· 3 months ago
3a184c3
[ISSUE #10021] Optimize consumer type check with EnumSet (#10022)
by yx9o
· 3 months ago
24ca9e4
[ISSUE #10043] Make TimerMessageReputService thread pool configurable and shutdown gracefully (#10044)
by wizcraft_kris
· 3 months ago
9ad4a1b
[ISSUE #9988] Remove mismatched response header in getConsumerConnectionList (#9989)
by yx9o
· 3 months ago
c7892a6
[ISSUE #9852] Print full message when CRC not found in properties (#9853)
by guyinyou
· 3 months ago
90b0906
[ISSUE #10038] Fix checkCommitLogOffsetOnRecover to skip validation for BLANK_MAGIC_CODE messages (#10039)
by guyinyou
· 3 months ago
50e7ffa
[ISSUE #10040] Ignore flattened-pom.xml files generated by maven (#10041)
by yx9o
· 4 months ago
236ede2
Fix: avoid extra padding when message end position is already page-aligned (#10036)
by guyinyou
· 4 months ago
4aa6cdd
[ISSUE #10019] Revert "[ISSUE #8127]Optimize the metric calculation logic of the time wheel" (#10020)
by rongtong
· 4 months ago
94ba5e1
[ISSUE #10031] Add PreprocessHandler interface in AllocateMappedFileService
by guyinyou
· 4 months ago
36adf12
[ISSUE #10017] Validate commitlog offset in recoverAbnormally to prevent processing … (#10018)
by guyinyou
· 4 months ago
899a1b5
[ISSUE #10023] Remove duplicate shutdown and rejection handler calls for routeThreadPoolExecutor (#10024)
by wizcraft_kris
· 4 months ago
2eb537c
[ISSUE #9980] Skip invalid Pop records when consumer group does not exist (#9982)
by Aman Gautam
· 4 months ago
ee10411
[ISSUE #10015] Optimize writeWithoutMmap. add page alignment to avoid read-modify-write
by guyinyou
· 4 months ago
1b6a919
[RIP-83] Lite Topic: A New Message Model (#9800)
by Quan
· 4 months ago
45fc4e0
[ISSUE #10005] Fix switch-case logic in updateConsumerOffsetAsync (#10006)
by yx9o
· 4 months ago
3d3a2d0
[ISSUE #9975] Bump broker rocksdb from 1.0.2 to 1.0.6 (#10002)
by lizhimins
· 4 months ago
527bb98
[ISSUE #9900] Supports sending heartbeats to the broker concurrently (#9901)
by wizcraft_kris
· 4 months ago
500c468
[ISSUE #9978] Remove static from loadJsonConfig and unify exception strings (#9979)
by yx9o
· 4 months ago
b6cc188
[ISSUE #9992] Fix remoting server netty server codec thread reuse problem (#9993)
by ymwneu
· 4 months ago
4eead13
[ISSUE #9912] Reduce excessive requests for consumer offset timestamps in tiered storage (#9991)
by lizhimins
· 4 months ago
9fecafe
[ISSUE #9953] Fix: there's no need to decompress message body in server side (#9954)
by Humkum
· 4 months ago
ae69814
[ISSUE #9923] Transactional messages should not send custom delayed messages (#9924)
by yx9o
· 4 months ago
4c66580
[ISSUE #9994] Improve switchTimerEngine command with OptionGroup validation (#9995)
by majialong
· 4 months ago
7fc5452
[ISSUE #9970] Refactor the MessageQueueSelector to support more flexible queue selection strategy (#9971)
by qianye
· 4 months ago
9f23894
[ISSUE #9980] Skip invalid records when the group is absent in Pop (#9981)
by lizhimins
· 4 months ago
6ab57ad
[ISSUE #9976] Update copyright year in NOTICE file to 2026 (#9977)
by mxsm
· 4 months ago
cbe72c7
[ISSUE #9962] Fix the failure of fastjson2 parsing metricsExporterType in proxy config (#9963)
by yuz10
· 4 months ago
7cc0774
[ISSUE #9964] Rename intConfig method to initConfig (#9965)
by yx9o
· 4 months ago
1117ab8
[ISSUE #9780] Skip unnecessary RPC when topic has no message queues (#9781)
by yx9o
· 4 months ago
b5da00a
[ISSUE #9936] Release Apache RocketMQ 5.4.0 (#9937)
by lizhimins
· 4 months 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
· 4 months ago
541fdad
[ISSUE #9947] Fix TimerMessageStore.checkAndReviseMetrics throws BufferUnderflowException (#9948)
by gaoyf
· 4 months ago
79e7003
[ISSUE #9945] Use UniqueKey as TimerDelKey by default
by imzs
· 4 months ago
5132258
Fix epoch truncate (#9942)
by littleboy
· 4 months ago
fef690c
[ISSUE #9943] Remove redundant containsKey check in checkBrokerConfig (#9944)
by yx9o
· 4 months ago
Next »