Commit Graph

  • 9c0cc510dc [ISSUE #10189] Remove unused fetchRemoteConfigExecutorService in MQClientInstance (#10190) develop wizcraft_kris 2026-03-31 17:04:47 +08:00
  • 459d27b39f [ISSUE #10191] Fix wrong option value for namesrvAddr parsing in timer benchmark examples (#10192) majialong 2026-03-31 15:33:05 +08:00
  • 3b12a25f0a [ISSUE #10076] Make orderly resetOffset wait on consume lock while preserving timeout semantics (#10175) Lystran 2026-03-31 10:37:13 +08:00
  • d66cfa9d7a [ISSUE #10165] Prevent RocksDB metrics from being overwritten after timer engine switch (#10166) hqbfz 2026-03-30 16:48:33 +08:00
  • 7d7eb73e03 [ISSUE #10003] Add gRPC maxConcurrentCallsPerConnection Configuration to Proxy (#10004) qianye 2026-03-30 14:27:01 +08:00
  • e5d33722d9 [ISSUE #10223] Not query the index of system topics in tiered storage (#10224) lizhimins 2026-03-30 13:34:53 +08:00
  • 103b7bcc3c [ISSUE #10229] Fix server-side reset offset does not take effect for FIFO (orderly) pop consumers (#10230) qianye 2026-03-30 11:53:04 +08:00
  • 35c88e3094 [ISSUE #10225] Add RejectedExecutionHandler support for ThreadPoolMonitor (#10222) ltamber 2026-03-30 09:40:11 +08:00
  • b14f926d64 Remove some workflows (#10220) rongtong 2026-03-27 18:13:02 +08:00
  • 932588d3e1 [ISSUE #10201] Optimize queryOffset method overloads in IndexService (#10202) yx9o 2026-03-25 15:24:21 +08:00
  • 59033a3653 [ISSUE #10199] Fix stale write timestamp leads to duplicate transaction commit (#10200) lizhimins 2026-03-25 15:06:01 +08:00
  • 8d451f3334 [ISSUE #10195] Ensure RocksDB compatibility in slave-master synchronization (#10196) gaoyf 2026-03-24 16:58:17 +08:00
  • e1007439e5 [ISSUE #10181] Some minor fixes in PopConsumerService (#10182) lizhimins 2026-03-23 11:39:52 +08:00
  • aea4177655 [ISSUE #10171] Support custom JAVA_HOME on Linux in runbroker.sh and runserver.sh (#10172) majialong 2026-03-21 17:34:39 +08:00
  • ebf1595418 [ISSUE #10103] Improve batch polling efficiency in pollIndexRecord method (#10104) yx9o 2026-03-17 16:22:28 +08:00
  • 2bc1783f54 [ISSUE #10168] Fix GetAllTopicConfigResponseHeader compatibility issue (#10169) gaoyf 2026-03-17 15:18:30 +08:00
  • 34648ed60f [ISSUE #10161] reduce bytes copy in json encode(#10162) ChineseTony 2026-03-17 10:33:25 +08:00
  • 7c10c7707d [ISSUE #10154] Rename BrokerConsumeStatsSubCommad to BrokerConsumeStatsSubCommand (#10155) yx9o 2026-03-17 10:28:42 +08:00
  • 7742b7c12d [ISSUE #10157] Fix tiered metadata leak after topic delete (#10158) SHI 2026-03-17 10:15:00 +08:00
  • 70834e3db5 [ISSUE #10009] Convert internal-only public classes to inner classes and add null-check log (#10028) sinberCS 2026-03-13 15:35:40 +08:00
  • 4a29b7e0bf [ISSUE #10077] Support password-encrypted private keys for Proxy TLS (#10078) majialong 2026-03-13 14:27:49 +08:00
  • 4c9f7a9139 [ISSUE #10159] Fix unstable tests in DefaultMQLitePullConsumerWithTraceTest (#10160) yx9o 2026-03-13 14:16:48 +08:00
  • 628230d22c [ISSUE #10011] Optimize accelerated recovery process and refactor code (#10012) rongtong 2026-02-28 10:30:15 +08:00
  • 7030c458ba [ISSUE #10061]Optimize the issue/pull request template of RocketMQ (#10062) mxsm 2026-02-27 16:33:21 +08:00
  • 330dccc6b4 [ISSUE #10107] Fix fastjson2 integer overflow when parsing AtomicLong (#10112) yx9o 2026-02-25 09:29:22 +08:00
  • bd1038aef1 [ISSUE #10110] Plain request process success and response fail when tlsMode=enforcing (#10111) yuz10 2026-02-24 13:56:52 +08:00
  • 7be720250e [ISSUE #10108] Broker startup fail in recover (#10109) yuz10 2026-02-24 13:56:23 +08:00
  • b8f8856868 [ISSUE #10105] Fix ClassCastException in getLocks() method (#10106) yx9o 2026-02-23 14:43:45 +08:00
  • 6df8246eca Upgraded Netty to 4.1.130.Final to remediate CVEs (#10090) shub-est 2026-02-13 12:07:29 +00:00
  • 2c70ce604f Upgraded Bouncy Castle to remediate CVEs (#10102) shub-est 2026-02-12 03:02:05 +00:00
  • 5bca8f03c8 Upgraded LZ4 and migrated to newer group id (#10092) shub-est 2026-02-12 01:56:00 +00:00
  • d650a2df8e Bump commons-validator from 1.7 to 1.10.0 (#10070) (#10081) codez 2026-02-12 09:50:19 +08:00
  • 76cd3892e7 [ISSUE #10093] Enhance delayed message type validation in batch send (#10094) yx9o 2026-02-11 17:03:53 +08:00
  • a6be1eec70 [ISSUE # 10086] Fix timer engine switch to persist correct config key (#10085) liuzhenyu 2026-02-11 14:14:15 +08:00
  • 35d69cbf75 [ISSUE #10095] Upgraded Commons Lang3 to remediate CVEs (#10096) shub-est 2026-02-11 03:59:26 +00:00
  • ec7db8dc79 [ISSUE #10082] Missing PROPERTY_TIMER_DELAY_MS property check in delay message type validation (#10084) dingshuangxi888 2026-02-10 13:48:45 +08:00
  • c197e50f8d [ISSUE #10079] FlushConsumeQueueService: always flush store checkpoint after CQ flush (#10080) guyinyou 2026-02-09 17:38:03 +08:00
  • 1754cece4b Restore the lost PR 3460 (#10067) gaoyf 2026-02-06 15:30:15 +08:00
  • 26480ddc87 [ISSUE #10073] Fix StoreCheckpoint logicsMsgTimestamp to reflect flushed consume queue storetime (#10074) guyinyou 2026-02-05 22:34:12 +08:00
  • d254f791f2 [ISSUE #10071] Fix PopLiteLongPollingService#cleanUnusedResource Quan 2026-02-05 17:51:47 +08:00
  • c2c674dcd4 [ISSUE #10068] Remove duplicate registration in DefaultMessagingProcessor.init (#10069) yx9o 2026-02-05 13:57:09 +08:00
  • 7fe0349f71 [ISSUE #10063] Notification request adds subscription expression to support on-demand wake-up (#10064) qianye 2026-02-05 10:55:32 +08:00
  • a6c5604b6c [ISSUE #10046] Fix lock leak risk in sendHeartbeatToBroker (#10047) yx9o 2026-02-05 09:50:22 +08:00
  • 04711367b7 [ISSUE #9999] Mark custom delay time messages with delay type (#10000) yx9o 2026-02-05 09:48:45 +08:00
  • 10c650c487 [ISSUE #10034] Optimizing cq iterator and calculating lag (#10056) lizhimins 2026-02-02 21:01:46 +08:00
  • 93888428cc [ISSUE #9899] Forbid windows sync directory (#10057) gaoyf 2026-02-02 15:13:13 +08:00
  • f80753f0da [ISSUE #10050] Support ChangeInvisibleTime without incrementing message reconsume times (#10051) ltamber 2026-02-02 14:06:57 +08:00
  • 7583fda113 fix(store): close all consume queue file handles on ConsumeQueueStore shutdown (#10060) rongtong 2026-02-02 11:41:35 +08:00
  • 89d331c6ba [ISSUE #10054] Correct the output format for ConsumerRecords (#10055) yx9o 2026-02-02 10:52:11 +08:00
  • 3a184c3e9e [ISSUE #10021] Optimize consumer type check with EnumSet (#10022) yx9o 2026-01-30 10:05:48 +08:00
  • 24ca9e46b5 [ISSUE #10043] Make TimerMessageReputService thread pool configurable and shutdown gracefully (#10044) wizcraft_kris 2026-01-30 10:04:40 +08:00
  • 382821ce38 Bump org.assertj:assertj-core from 3.22.0 to 3.27.7 dependabot/maven/org.assertj-assertj-core-3.27.7 dependabot[bot] 2026-01-26 21:42:43 +00:00
  • 9ad4a1b947 [ISSUE #9988] Remove mismatched response header in getConsumerConnectionList (#9989) yx9o 2026-01-26 17:31:20 +08:00
  • c7892a694a [ISSUE #9852] Print full message when CRC not found in properties (#9853) guyinyou 2026-01-26 10:02:17 +08:00
  • 90b0906ae6 [ISSUE #10038] Fix checkCommitLogOffsetOnRecover to skip validation for BLANK_MAGIC_CODE messages (#10039) guyinyou 2026-01-26 10:01:49 +08:00
  • 50e7ffa4c8 [ISSUE #10040] Ignore flattened-pom.xml files generated by maven (#10041) yx9o 2026-01-22 11:55:56 +08:00
  • 236ede218a Fix: avoid extra padding when message end position is already page-aligned (#10036) guyinyou 2026-01-21 17:19:34 +08:00
  • 4aa6cdd99e [ISSUE #10019] Revert "[ISSUE #8127]Optimize the metric calculation logic of the time wheel" (#10020) rongtong 2026-01-21 14:15:00 +08:00
  • 94ba5e14f8 [ISSUE #10031] Add PreprocessHandler interface in AllocateMappedFileService guyinyou 2026-01-21 10:07:51 +08:00
  • 36adf1251f [ISSUE #10017] Validate commitlog offset in recoverAbnormally to prevent processing … (#10018) guyinyou 2026-01-20 14:44:22 +08:00
  • 899a1b5520 [ISSUE #10023] Remove duplicate shutdown and rejection handler calls for routeThreadPoolExecutor (#10024) wizcraft_kris 2026-01-20 14:09:02 +08:00
  • 2eb537cdaa [ISSUE #9980] Skip invalid Pop records when consumer group does not exist (#9982) Aman Gautam 2026-01-20 11:32:15 +05:30
  • ee104114ac [ISSUE #10015] Optimize writeWithoutMmap. add page alignment to avoid read-modify-write guyinyou 2026-01-16 17:59:02 +08:00
  • 1b6a919bde [RIP-83] Lite Topic: A New Message Model (#9800) Quan 2026-01-16 17:20:22 +08:00
  • 45fc4e0c7b [ISSUE #10005] Fix switch-case logic in updateConsumerOffsetAsync (#10006) yx9o 2026-01-15 10:58:35 +08:00
  • 3d3a2d032f [ISSUE #9975] Bump broker rocksdb from 1.0.2 to 1.0.6 (#10002) lizhimins 2026-01-14 13:45:45 +08:00
  • 527bb9872d [ISSUE #9900] Supports sending heartbeats to the broker concurrently (#9901) wizcraft_kris 2026-01-14 11:15:18 +08:00
  • 500c46866a [ISSUE #9978] Remove static from loadJsonConfig and unify exception strings (#9979) yx9o 2026-01-14 10:36:46 +08:00
  • b6cc188bfa [ISSUE #9992] Fix remoting server netty server codec thread reuse problem (#9993) ymwneu 2026-01-14 10:06:22 +08:00
  • 4eead1364d [ISSUE #9912] Reduce excessive requests for consumer offset timestamps in tiered storage (#9991) lizhimins 2026-01-13 09:56:22 +08:00
  • 9fecafe086 [ISSUE #9953] Fix: there's no need to decompress message body in server side (#9954) Humkum 2026-01-12 11:26:58 +08:00
  • ae6981453a [ISSUE #9923] Transactional messages should not send custom delayed messages (#9924) yx9o 2026-01-08 15:16:25 +08:00
  • 4c665802a2 [ISSUE #9994] Improve switchTimerEngine command with OptionGroup validation (#9995) majialong 2026-01-08 14:19:37 +08:00
  • 7fc5452e0d [ISSUE #9970] Refactor the MessageQueueSelector to support more flexible queue selection strategy (#9971) qianye 2026-01-07 15:40:09 +08:00
  • 9f23894180 [ISSUE #9980] Skip invalid records when the group is absent in Pop (#9981) lizhimins 2026-01-07 15:19:54 +08:00
  • 6ab57ad478 [ISSUE #9976] Update copyright year in NOTICE file to 2026 (#9977) mxsm 2026-01-06 19:22:03 +08:00
  • cbe72c7b6a [ISSUE #9962] Fix the failure of fastjson2 parsing metricsExporterType in proxy config (#9963) yuz10 2026-01-06 10:07:53 +08:00
  • 7cc077416e [ISSUE #9964] Rename intConfig method to initConfig (#9965) yx9o 2026-01-04 17:46:20 +08:00
  • 1117ab8f97 [ISSUE #9780] Skip unnecessary RPC when topic has no message queues (#9781) yx9o 2025-12-30 11:49:11 +08:00
  • b5da00ad0f [ISSUE #9936] Release Apache RocketMQ 5.4.0 (#9937) rocketmq-all-5.4.0 release-5.4.0 lizhimins 2025-12-24 15:24:57 +08:00
  • 4b187c6e11 [ISSUE #9945] Use UniqueKey as the TimerDelKey value when no namespace is appended (#9951) imzs 2025-12-24 13:48:47 +08:00
  • 541fdad0ff [ISSUE #9947] Fix TimerMessageStore.checkAndReviseMetrics throws BufferUnderflowException (#9948) gaoyf 2025-12-24 11:27:59 +08:00
  • 79e700312a [ISSUE #9945] Use UniqueKey as TimerDelKey by default imzs 2025-12-24 10:00:01 +08:00
  • 5132258db9 Fix epoch truncate (#9942) littleboy 2025-12-24 09:31:42 +08:00
  • fef690c06d [ISSUE #9943] Remove redundant containsKey check in checkBrokerConfig (#9944) yx9o 2025-12-24 09:31:19 +08:00
  • 684e73311f [ISSUE #9938] Rename misnamed Messing classes to Messaging (#9939) yx9o 2025-12-23 10:50:58 +08:00
  • fe5c17cb8b Optimized the function naming (#9935) Drizzle 2025-12-19 16:03:49 +08:00
  • 02412eba59 [ISSUE #9933] Fix the failure when RocksDBConfigToJsonCommand exports locally. (#9934) rongtong 2025-12-19 10:03:30 +08:00
  • 0792474479 [ISSUE #9928] Add Priority IT for GRPC protocol imzs 2025-12-19 09:39:16 +08:00
  • c1ccc3ce00 [ISSUE #9914] Simplify isolation logic when updating fault item in sendKernelImpl (#9915) yx9o 2025-12-18 20:48:08 +08:00
  • 6fa05ff6f9 [ISSUE #9921] Limit the concurrency of Pop revive (#9922) lizhimins 2025-12-18 20:42:52 +08:00
  • 8c7bf5225a [ISSUE #9902] Remove unnecessary String.format (#9903) yx9o 2025-12-18 20:00:21 +08:00
  • bdae09ddf2 [RIP-80] #9928 Implementation of Priority Message (#9929) imzs 2025-12-18 10:18:25 +08:00
  • 9f9cab88ba [ISSUE #9396] replace fastjson with fastjson2 (#9927) yuz10 2025-12-16 19:11:01 +08:00
  • 71659e35f2 [ISSUE #8903] fix dledger mode expired message can not delete on jdk9+ (#9851) littleboy 2025-12-15 15:09:01 +08:00
  • beee84fa44 [ISSUE #9868] Fix getBrokerEpoch no response issue for empty parameters (#9869) yx9o 2025-12-12 16:26:48 +08:00
  • 15796e73d3 [ISSUE #9912] Fix consumer offset timestamp displayed incorrect in tiered store (#9913) SHI 2025-12-12 16:10:09 +08:00
  • 6f5b551b88 [ISSUE #9918] Fix the message may be renewed once more if the gRPC push consumer is unexpectedly disconnected (#9919) qianye 2025-12-12 16:08:46 +08:00
  • 7a08b4cb68 [RIP-82] Implement Timer message, transaction message, and index based on RocksDB (#9787) Drizzle 2025-12-11 15:13:56 +08:00
  • f73fe6c4fb [ISSUE #9885] Fix tiered store cache count and bytes metrics (#9886) majialong 2025-12-11 10:27:08 +08:00