Sign in
apache
/
rocketmq
/
HEAD
b37e2bb
[ISSUE #10639] Reuse a per-thread scratch buffer in CommitLog.checkMessageAndReturnSize (#10640)
by Jiahua Wang
· 27 hours ago
develop
577b89f
[ISSUE #10644] Add LMQ number gauge metric to Broker observability (#10645)
by Quan
· 3 days ago
4f9b187
[ISSUE #10569] Support Lite Simple Consumer on server side (#10570)
by Quan
· 5 days ago
26cfb5f
[ISSUE #10622] Resolve ConsumerOffsetManager dynamically in LiteEventDispatcher (#10623)
by Quan
· 7 days ago
3373f28
[ISSUE #10613] Fix async request-reply RequestCallback firing multiple times (#10614)
by Jiahua Wang
· 7 days ago
45254d5
[ISSUE #10615] Fix missing long-polling notification under CombineConsumeQueue selective double-write (#10616)
by imzs
· 11 days ago
74e90f7
[ISSUE #10446] Support batch deletion of topics and subscription groups in broker (#10448)
by Jiahua Wang
· 12 days ago
c4ce550
[ISSUE #10604] Fix TopicConfig DataVersion not persisted in split registration (#10605)
by imzs
· 2 weeks ago
0e4ccf1
[ISSUE #10578] Fix master election maxOffset comparator overflow
by aias00
· 2 weeks ago
2af604f
[ISSUE #10593] Rename CLusterSendMsgRTCommand to ClusterSendMsgRTCommand (#10594)
by yx9o
· 3 weeks ago
8242c1e
[ISSUE #10562] Optimize PopConsumerServiceTest#transferToFsStoreTest to avoid unnecessary background threads (#10563)
by Quan
· 3 weeks ago
1730dbc
[ISSUE #10560] Remove enableLiteEventMode config switch (#10561)
by Quan
· 3 weeks ago
88709c5
[ISSUE #10543] resolve data race in ServiceThread wakeup mechanism (#10544)
by SSpirits
· 4 weeks ago
f4c0c4d
docs: format README for consistent Markdown style (#10551)
by Surya Kant
· 4 weeks ago
49102a9
[ISSUE #10549] Fix lite topic reset offset: memory leak, FIFO block bypass, and offset-0 reset failure (#10550)
by Quan
· 4 weeks ago
10d498c
[ISSUE-10546] Add default implementation for rejectRequest() in NettyRequestProcessor (#10547)
by Quan
· 4 weeks ago
2e6632f
[ISSUE #10417] Fix stale minOffset after consumeQueue truncation (#10418)
by chenxu80
· 4 weeks ago
b5bc1ff
Fix flaky HATest semi-sync replication (#10495)
by rongtong
· 5 weeks ago
c4ae761
docs: fix broker container reference and producer typos (#10449)
by LeiXiaoGao
· 5 weeks ago
bfbbb2a
[#10421] Fix Timer message rocksdb use wrong cache key. (#10422)
by echooymxq
· 5 weeks ago
e213756
[ISSUE #10419] Fix NPE when class filter route data is missing (#10420)
by yin_bo_
· 5 weeks ago
c270c60
[ISSUE #10441] Reduce per-RPC allocation in metrics by caching static AttributeKey instances (#10443)
by Jiahua Wang
· 5 weeks ago
5977e9c
[ISSUE #10522] Reduce Remoting header encoding allocation via FastCodesHeader/RocketMQSerializable optimizations
by Jiahua Wang
· 5 weeks ago
f941dce
[ISSUE #10521] Use madvise(MADV_RANDOM) to disable kernel read-ahead during correctMinOffset binary search (#10523)
by lizhimins
· 5 weeks ago
971d568
[ISSUE #10515] Fix TransactionMetricsFlushService busy spin bug (#10517)
by Jiahua Wang
· 5 weeks ago
9b91157
[ISSUE #10486] Add getMessageType(Map) overload to eliminate redundant properties decode (#10487)
by Jiahua Wang
· 5 weeks ago
e18f0d2
[ISSUE #10511] Replace Enum.values() loop with static array lookup in LanguageCode and SerializeType (#10513)
by Jiahua Wang
· 5 weeks ago
59a70d9
Update ACL mqadmin commands in Chinese doc Section 7 (#10504)
by KaiQuan Chen
· 6 weeks ago
226e24f
Fix outdated constructor signatures in trace documentation (#10501)
by KaiQuan Chen
· 6 weeks ago
4082e31
[ISSUE #8262]Fix bitsarray off by one (#10506)
by KaiQuan Chen
· 6 weeks ago
7347c44
[ISSUE #10510] Add gRPC server permit keepalive configuration (#10516)
by RockteMQ-AI
· 6 weeks ago
b4d92c0
[ISSUE #10492] Add debug logging for swallowed exceptions in StatsAllSubCommand (#10493)
by SGloria
· 6 weeks ago
da58317
[ISSUE #10216] Fix potential NPE in EscapeBridge when topicPublishInfo is null (#10507)
by SGloria
· 6 weeks ago
c4f18d9
[DOCS] Fix typos in documentation filenames (#10505)
by quzizii
· 6 weeks ago
3a56824
docs: fix dead link to tiered store config in tieredstore README (#10484)
by fancy
· 6 weeks ago
c830191
docs: remove dead Slack invite link from README (#10483)
by fancy
· 6 weeks ago
91cb333
[ISSUE #10462] Improve error handling in tiered storage (#10473)
by lizhimins
· 6 weeks ago
1ab9689
[ISSUE #10450] Selective double-write in CombineConsumeQueueStore (#10452)
by imzs
· 6 weeks ago
8a589c6
[ISSUE #10453] Fix unexpected decrement of lmq counter (#10454)
by imzs
· 6 weeks ago
cf9113f
[ISSUE #10462] Fix resource leaks and lifecycle issues in tiered storage (#10476)
by lizhimins
· 6 weeks ago
801d6c0
[ISSUE #10467] Reduce per-message allocation in createUniqID and valueOfMagicCode (#10469)
by Jiahua Wang
· 6 weeks ago
78e680b
[ISSUE #10462] Standardize log format across tiered storage module (#10474)
by lizhimins
· 6 weeks ago
84fc240
[ISSUE #10462] Optimize thread pool sizes for commit and fetch executors (#10472)
by lizhimins
· 6 weeks ago
68cc743
[Fix #10460]: Pre-size ProxyContext map to avoid HashMap resize on request path (#10461)
by Harsh Mehta
· 6 weeks ago
976e9a3
[ISSUE #10435] Fix shared ClientChannelInfo preventing inactive channel expiry (#10437)
by Chuan
· 6 weeks ago
21562bb
[ISSUE #10462] Fix concurrency bugs in tiered storage (#10471)
by lizhimins
· 6 weeks ago
da9b26b
[ISSUE #10438] Fix buildTopicConfigSerializeWrapper exposing live topicConfigTable reference (#10439)
by Chuan
· 6 weeks ago
86d1df4
[ISSUE #10475] Add unit tests for CleanupPolicyUtils
by quzizii
· 6 weeks ago
50ae7c5
[ISSUE #10462] Add memory backpressure to dispatch (#10470)
by lizhimins
· 6 weeks ago
be38a82
Configure GitHub workflows to use concurrency cancel-in-progress for (#10445)
by Aurélien Pupier
· 6 weeks ago
8997e8c
fix: validate message batch input (#10459)
by LeiXiaoGao
· 6 weeks ago
6339431
docs: fix inaccurate examples and typos across developer guides (#10456)
by lsq3497
· 6 weeks ago
86ccea0
docs: fix broker IP typo in startup examples (#10440)
by LeiXiaoGao
· 6 weeks ago
2319d2f
[ISSUE #10457] Fix RocketmqColdCtr logger level (#10447)
by bruce
· 6 weeks ago
ef6a8c9
[ISSUE #10430] Add unit tests for srvutil package (#10431)
by lsq3497
· 7 weeks ago
82a6a78
[ISSUE #10423] Optimize LiteConsumerLagCalculator.getLagCountTopK by deferring getStoreTimestamp to topK results only (#10424)
by Quan
· 7 weeks ago
216fc1b
[ISSUE #10345] fix: preserve lite topic for auto-renew receipt handles (#10346)
by wizcraft_kris
· 7 weeks ago
7e0cec3
[ISSUE #10425] Revert split registration dataVersion change (#10426)
by rongtong
· 7 weeks ago
5272736
[ISSUE #10389] Fix or ignore several flaky tests of PopPriorityIT (#10390)
by imzs
· 7 weeks ago
2a9560c
[ISSUE #10387] Support runtime hot-reload of maxClientEventCount in LiteEventDispatcher.ClientEventSet (#10388)
by Quan
· 7 weeks ago
610acb5
[ISSUE #10384] Enforce Lite exclusive subscription eviction via server-side tombstones (#10386)
by Quan
· 7 weeks ago
a6fb9e2
[ISSUE #10410] Fix RocksDBOptionsFactoryTest compile failure (#10411)
by rongtong
· 8 weeks ago
78b0546
[ISSUE #10398] Fix native memory leak on TLS certificate hot-reload (#10399)
by qianye
· 8 weeks ago
8561729
[ISSUE #10400] Cache Version.values() in MQVersion to avoid repeated array allocation (#10401)
by qianye
· 8 weeks ago
e12d755
[ISSUE #10344] Parameterize RocksDB CQ size amplification
by rongtong
· 8 weeks ago
a705dbc
[ISSUE #10393] Fix outdated FAQ documentation URL in FAQUrl (#10394)
by majialong
· 8 weeks ago
9443c6d
[ISSUE #10383] Align Bazel dependencies with Maven pom.xml (#10404)
by lizhimins
· 8 weeks ago
c9e51d6
[ISSUE #10381] Make HashedWheelTimer parameters configurable in QueueLevelConsumerOrderInfoLockManager (#10382)
by Quan
· 8 weeks ago
41a3a35
[ISSUE #10373] Fix quarantined flaky tests and remove CI rerun workflow (#10379)
by lizhimins
· 9 weeks ago
051ba27
[DOCS] Update Chinese docs dependency version from 4.3.0/4.9.1 to 5.5.0 (#10358)
by H145608
· 9 weeks ago
9e2d877
[ISSUE #10375] Fix race condition between deleteTopic and FlushConsumeQueueService by removing getLifeCycle indirection (#10376)
by Quan
· 9 weeks ago
980f3d7
[ISSUE #10373] Quarantine flaky tests and add detection plan docs (#10374)
by lizhimins
· 9 weeks ago
eb95ba3
[DOCS] Fix typo in Troubleshooting.md filename (#10360)
by H145608
· 9 weeks ago
7e5d22d
[ISSUE #10334] Make native CqCompactionFilter shim self-contained without rocksdbjni dependency (#10371)
by lizhimins
· 9 weeks ago
1251c9a
[ISSUE #10280] Restore opaque when proxy remoting forward fails (#10281)
by yx9o
· 9 weeks ago
54708be
[DOCS] Update example dependency version from 4.3.0 to 5.5.0 (#10349)
by H145608
· 9 weeks ago
079038d
[ISSUE #10247] Remove duplicate remove call in InvocationChannel (#10248)
by yx9o
· 9 weeks ago
61c493c
[ISSUE #10334] Support native CqCompactionFilter with cross-platform JNI shim (#10335)
by lizhimins
· 9 weeks ago
a3abd51
[ISSUE #10341] Fix Bazel CI build failure caused by Maven Central rate limiting (#10342)
by lizhimins
· 10 weeks ago
17b4e56
[ISSUE #10285] Fix preserve popTime when rebuilding AckResult (#10286)
by yx9o
· 10 weeks ago
c625406
[ISSUE #10291] fix queryMessage default index type (#10292)
by yuz10
· 2 months ago
c5a4da5
[ISSUE #10297] Set brokerName for messages returned by proxy local POP path (#10298)
by yx9o
· 2 months ago
bd903d5
[ISSUE #10284] Fix consumerOffset deserialization error and add test (#10287)
by ChineseTony
· 2 months ago
c6fc39a
[ISSUE #10276] Fix PopConsumerService changeInvisibilityDuration losing CK record when visibilityTimeout collision (#10277)
by qianye
· 3 months ago
5ad6a3e
[ISSUE #10274] Fix ForwardMessageToDeadLetterQueue request mapping descriptor (#10275)
by wizcraft_kris
· 3 months ago
c083052
[ISSUE #10253] Fix stale wildcardGroupMap entries caused by incorrect parsing during LiteTopic wildcard unregistration (#10254)
by wizcraft_kris
· 3 months ago
0752ddf
[ISSUE #10270] Make Pop RocksDB BlockCache size configurable via MessageStoreConfig (#10271)
by lizhimins
· 3 months ago
f04eafc
[ISSUE #10266] Fix OOM caused by OpenTelemetry 1.44 OtlpGrpcMetricExporter pool race (#10267)
by Houlong66
· 3 months ago
94fbfcf
[ISSUE #10268] Fix incorrect time range file selection in IndexStoreService.queryAsync (#10269)
by lizhimins
· 3 months ago
840b18c
[ISSUE #10260] Reject delayed transactional messages in gRPC send path (#10261)
by yx9o
· 3 months ago
9879968
[ISSUE #10238] Release Apache RocketMQ 5.5.0 (#10251)
by lizhimins
· 4 months ago
rocketmq-all-5.5.0
b8aba3b
[ISSUE #10181] Remove lock when resetting offset in PopConsumerService (#10250)
by lizhimins
· 4 months ago
2b5e709
[ISSUE #9777 ]feat: use data version from master while sync slave and fix delete co… (#9778)
by Vincent Lee
· 4 months ago
343daa9
[ISSUE #10173] Improve PopLite: rename RocksDB CQ path and schedule autoClean (#10242)
by imzs
· 4 months ago
7b85a5d
[ISSUE #10240] Add BatchSplittingMetricExporter to prevent OTLP gRPC export failures (#10239)
by Houlong66
· 4 months ago
2c2cc92
[ISSUE #10173] Support LMQ in CombineConsumeQueueStore without migration to RocksDB CQ (#10174)
by imzs
· 4 months ago
614b816
[ISSUE #10203] Support wildcard subscription and and consumer suspend for LiteTopic (#10204)
by Quan
· 4 months ago
860de80
[ISSUE #10183] Fix incorrect brokerName when constructing processQueueTable with static topic (#10186)
by wizcraft_kris
· 4 months ago
d68d5a5
[ISSUE #10183] Fix incorrect brokerName when constructing ProcessQueueTable with static topic (#10184)
by wizcraft_kris
· 4 months ago
9c0cc51
[ISSUE #10189] Remove unused fetchRemoteConfigExecutorService in MQClientInstance (#10190)
by wizcraft_kris
· 4 months ago
Next »