opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity
9,012 Commits 72 Branches 40 Tags
50e7ffa4c8288bb9f0789bda6422a3d0b7220d70
Commit Graph

9012 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
yx9o 50e7ffa4c8 [ISSUE #10040] Ignore flattened-pom.xml files generated by maven (#10041) 2026-01-22 11:55:56 +08:00
guyinyou 236ede218a Fix: avoid extra padding when message end position is already page-aligned (#10036) 
Change-Id: I3e7fad9c4b194b20015414bcceb830760df68fea

Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2026-01-21 17:19:34 +08:00
rongtong 4aa6cdd99e [ISSUE #10019] Revert "[ISSUE #8127]Optimize the metric calculation logic of the time wheel" (#10020) 
* Revert "[ISSUE #8127]Optimize the metric calculation logic of the time wheel"

* Revert "[ISSUE #8127]Optimize the metric calculation logic of the time wheel"

* Revert "[ISSUE #8127]Optimize the metric calculation logic of the time wheel"

---------

Co-authored-by: RongtongJin <user@example.com>
 2026-01-21 14:15:00 +08:00
guyinyou 94ba5e14f8 [ISSUE #10031] Add PreprocessHandler interface in AllocateMappedFileService 
Change-Id: I4e81916a79f89c095ffb7b860c8ccd49e88c76ea

Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2026-01-21 10:07:51 +08:00
guyinyou 36adf1251f [ISSUE #10017] Validate commitlog offset in recoverAbnormally to prevent processing … (#10018) 
* validate commitlog offset in recoverAbnormally to prevent processing old file data that passes CRC checks

Change-Id: If4b1881f82d26ce8d374472d73ec9ce3d51ba643

* fix

Change-Id: Idc4bf7ec476cc9b6529619c2aa9afd6a980b819c

* add checkCommitLogOffsetOnRecover in MessageStoreConfig

Change-Id: Iac9afbb8b3ffb03fa15890decaf502afbfa44cf9

---------

Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2026-01-20 14:44:22 +08:00
wizcraft_kris 899a1b5520 [ISSUE #10023] Remove duplicate shutdown and rejection handler calls for routeThreadPoolExecutor (#10024) 2026-01-20 14:09:02 +08:00
Aman Gautam 2eb537cdaa [ISSUE #9980] Skip invalid Pop records when consumer group does not exist (#9982) 
Signed-off-by: Aman Gautam <amangautam2128@gmail.com>
 2026-01-20 14:02:15 +08:00
guyinyou ee104114ac [ISSUE #10015] Optimize writeWithoutMmap. add page alignment to avoid read-modify-write 
Change-Id: I41ae3b71a4803295c2487cdf8f5e458764b64ebc

Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2026-01-16 17:59:02 +08:00
Quan 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
yx9o 45fc4e0c7b [ISSUE #10005] Fix switch-case logic in updateConsumerOffsetAsync (#10006) 2026-01-15 10:58:35 +08:00
lizhimins 3d3a2d032f [ISSUE #9975] Bump broker rocksdb from 1.0.2 to 1.0.6 (#10002) 
* [ISSUE #9975] Bump broker rocksdb from 1.0.2 to 1.0.5

Change-Id: Ic5c9e959d6ab532a92167bf562912b6008041df6

* [ISSUE #9975] Bump broker rocksdb from 1.0.2 to 1.0.6
 2026-01-14 13:45:45 +08:00
wizcraft_kris 527bb9872d [ISSUE #9900] Supports sending heartbeats to the broker concurrently (#9901) 2026-01-14 11:15:18 +08:00
yx9o 500c46866a [ISSUE #9978] Remove static from loadJsonConfig and unify exception strings (#9979) 2026-01-14 10:36:46 +08:00
ymwneu b6cc188bfa [ISSUE #9992] Fix remoting server netty server codec thread reuse problem (#9993) 
Co-authored-by: maowei.ymw <maowei.ymw@alibaba-inc.com>
 2026-01-14 10:06:22 +08:00
lizhimins 4eead1364d [ISSUE #9912] Reduce excessive requests for consumer offset timestamps in tiered storage (#9991) 
* [ISSUE #9912] Reduce excessive requests for consumer offset timestamps in tiered storage

Signed-off-by: terrance.lzm <terrance.lzm@alibaba-inc.com>

* [ISSUE #9912] Reduce excessive requests for consumer offset timestamps in tiered storage

---------

Signed-off-by: terrance.lzm <terrance.lzm@alibaba-inc.com>
 2026-01-13 09:56:22 +08:00
Humkum 9fecafe086 [ISSUE #9953] Fix: there's no need to decompress message body in server side (#9954) 2026-01-12 11:26:58 +08:00
yx9o ae6981453a [ISSUE #9923] Transactional messages should not send custom delayed messages (#9924) 
* [ISSUE #9923] Transactional messages should not send custom delayed messages

* Transactional messages do not support delayed delivery
 2026-01-08 15:16:25 +08:00
majialong 4c665802a2 [ISSUE #9994] Improve switchTimerEngine command with OptionGroup validation (#9995) 2026-01-08 14:19:37 +08:00
qianye 7fc5452e0d [ISSUE #9970] Refactor the MessageQueueSelector to support more flexible queue selection strategy (#9971) 2026-01-07 15:40:09 +08:00
lizhimins 9f23894180 [ISSUE #9980] Skip invalid records when the group is absent in Pop (#9981) 
Signed-off-by: terrance.lzm <terrance.lzm@alibaba-inc.com>
 2026-01-07 15:19:54 +08:00
mxsm 6ab57ad478 [ISSUE #9976] Update copyright year in NOTICE file to 2026 (#9977) 2026-01-06 19:22:03 +08:00
yuz10 cbe72c7b6a [ISSUE #9962] Fix the failure of fastjson2 parsing metricsExporterType in proxy config (#9963) 2026-01-06 10:07:53 +08:00
yx9o 7cc077416e [ISSUE #9964] Rename intConfig method to initConfig (#9965) 2026-01-04 17:46:20 +08:00
yx9o 1117ab8f97 [ISSUE #9780] Skip unnecessary RPC when topic has no message queues (#9781) 2025-12-30 11:49:11 +08:00
lizhimins b5da00ad0f [ISSUE #9936] Release Apache RocketMQ 5.4.0 (#9937) rocketmq-all-5.4.0 2025-12-24 15:24:57 +08:00
imzs 4b187c6e11 [ISSUE #9945] Use UniqueKey as the TimerDelKey value when no namespace is appended (#9951) 2025-12-24 13:48:47 +08:00
gaoyf 541fdad0ff [ISSUE #9947] Fix TimerMessageStore.checkAndReviseMetrics throws BufferUnderflowException (#9948) 2025-12-24 11:27:59 +08:00
imzs 79e700312a [ISSUE #9945] Use UniqueKey as TimerDelKey by default 2025-12-24 10:00:01 +08:00
littleboy 5132258db9 Fix epoch truncate (#9942) 2025-12-24 09:31:42 +08:00
yx9o fef690c06d [ISSUE #9943] Remove redundant containsKey check in checkBrokerConfig (#9944) 2025-12-24 09:31:19 +08:00
yx9o 684e73311f [ISSUE #9938] Rename misnamed Messing classes to Messaging (#9939) 2025-12-23 10:50:58 +08:00
Drizzle fe5c17cb8b Optimized the function naming (#9935) 
* add isWakeCommitWhenPutMessage  for AIO

* optimzie the Function name

Change-Id: Id91e3eb9c4488fb9804fb2c105082657e66c44c0

* optimized the function naming

Change-Id: Ifc482f91220ff328e5c5425a57a04ac627e8d469

---------

Co-authored-by: drizzle.zk <drizzle.zk@alibaba-inc.com>
 2025-12-19 16:03:49 +08:00
rongtong 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
imzs 0792474479 [ISSUE #9928] Add Priority IT for GRPC protocol 2025-12-19 09:39:16 +08:00
yx9o c1ccc3ce00 [ISSUE #9914] Simplify isolation logic when updating fault item in sendKernelImpl (#9915) 2025-12-18 20:48:08 +08:00
lizhimins 6fa05ff6f9 [ISSUE #9921] Limit the concurrency of Pop revive (#9922) 2025-12-18 20:42:52 +08:00
yx9o 8c7bf5225a [ISSUE #9902] Remove unnecessary String.format (#9903) 2025-12-18 20:00:21 +08:00
imzs bdae09ddf2 [RIP-80] #9928 Implementation of Priority Message (#9929) 
* #9928 Implementation of Priority Message

* switch to fastjson2

Change-Id: I3620b00b79a77a93a7cf0fdfac857fb495638ca6

* fix bazel CI, upgrade rocketmq-proto to 2.1.1

Change-Id: Ia66cc7b14b89dc319044ced5ba349315e487c849

* Fix bazel CI

* fix CI, temporarily disable popKv in OffsetResetForPopIT

Change-Id: I0b406cf0ece5067de430c4404aaa1f2dd46edcba

---------

Co-authored-by: RongtongJin <user@example.com>
 2025-12-18 10:18:25 +08:00
yuz10 9f9cab88ba [ISSUE #9396] replace fastjson with fastjson2 (#9927) 
* remove fastjson dependency

* remove fastjson

* revert

* revert
 2025-12-16 19:11:01 +08:00
littleboy 71659e35f2 [ISSUE #8903] fix dledger mode expired message can not delete on jdk9+ (#9851) 2025-12-15 15:09:01 +08:00
yx9o beee84fa44 [ISSUE #9868] Fix getBrokerEpoch no response issue for empty parameters (#9869) 2025-12-12 16:26:48 +08:00
SHI 15796e73d3 [ISSUE #9912] Fix consumer offset timestamp displayed incorrect in tiered store (#9913) 
Co-authored-by: shixiaoxiao <shixiaoxiao@bytedance.com>
 2025-12-12 16:10:09 +08:00
qianye 6f5b551b88 [ISSUE #9918] Fix the message may be renewed once more if the gRPC push consumer is unexpectedly disconnected (#9919) 
Change-Id: I00424612c5ee9dd30e5c155dab17262051e5f097
 2025-12-12 16:08:46 +08:00
Drizzle 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
majialong f73fe6c4fb [ISSUE #9885] Fix tiered store cache count and bytes metrics (#9886) 2025-12-11 10:27:08 +08:00
dingshuangxi888 1f387b286b Fix ACL 2.0: correct consumer group extraction from retry topic in SEND_MESSAGE/SEND_MESSAGE_V2/SEND_BATCH_MESSAGE (#9911) 2025-12-10 15:58:10 +08:00
rongtong 89e021e871 [ISSUE #9898] Remove AbstractBrokerRunnable and replace with Runnable 
Change-Id: I94104151c452d09cbe195a3e1126a473b662a337

Co-authored-by: RongtongJin <user@example.com>
 2025-12-05 14:03:54 +08:00
littleboy 1bb2168bf3 Fix controller mode HAService removeConnection (#9897) 
* fix controller mode HAService removeConnection

* fix store test
 2025-12-05 11:28:07 +08:00
qianye cbfd37b251 Add some log for gRPC route (#9896) 2025-12-05 10:19:27 +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