Google Git
Sign in
apache/rocketmq/HEAD
  1. aea4177 [ISSUE #10171] Support custom JAVA_HOME on Linux in runbroker.sh and runserver.sh (#10172) by majialong · 15 hours ago develop
  2. ebf1595 [ISSUE #10103] Improve batch polling efficiency in pollIndexRecord method (#10104) by yx9o · 5 days ago
  3. 2bc1783 [ISSUE #10168] Fix GetAllTopicConfigResponseHeader compatibility issue (#10169) by gaoyf · 5 days ago
  4. 34648ed [ISSUE #10161] reduce bytes copy in json encode(#10162) by ChineseTony · 5 days ago
  5. 7c10c77 [ISSUE #10154] Rename BrokerConsumeStatsSubCommad to BrokerConsumeStatsSubCommand (#10155) by yx9o · 5 days ago
  6. 7742b7c [ISSUE #10157] Fix tiered metadata leak after topic delete (#10158) by SHI · 5 days ago
  7. 70834e3 [ISSUE #10009] Convert internal-only public classes to inner classes and add null-check log (#10028) by sinberCS · 9 days ago
  8. 4a29b7e [ISSUE #10077] Support password-encrypted private keys for Proxy TLS (#10078) by majialong · 9 days ago
  9. 4c9f7a9 [ISSUE #10159] Fix unstable tests in DefaultMQLitePullConsumerWithTraceTest (#10160) by yx9o · 9 days ago
  10. 628230d [ISSUE #10011] Optimize accelerated recovery process and refactor code (#10012) by rongtong · 3 weeks ago
  11. 7030c45 [ISSUE #10061]Optimize the issue/pull request template of RocketMQ (#10062) by mxsm · 3 weeks ago
  12. 330dccc [ISSUE #10107] Fix fastjson2 integer overflow when parsing AtomicLong (#10112) by yx9o · 4 weeks ago
  13. bd1038a [ISSUE #10110] Plain request process success and response fail when tlsMode=enforcing (#10111) by yuz10 · 4 weeks ago
  14. 7be7202 [ISSUE #10108] Broker startup fail in recover (#10109) by yuz10 · 4 weeks ago
  15. b8f8856 [ISSUE #10105] Fix ClassCastException in getLocks() method (#10106) by yx9o · 4 weeks ago
  16. 6df8246 Upgraded Netty to 4.1.130.Final to remediate CVEs (#10090) by shub-est · 5 weeks ago
  17. 2c70ce6 Upgraded Bouncy Castle to remediate CVEs (#10102) by shub-est · 5 weeks ago
  18. 5bca8f0 Upgraded LZ4 and migrated to newer group id (#10092) by shub-est · 5 weeks ago
  19. d650a2d Bump commons-validator from 1.7 to 1.10.0 (#10070) (#10081) by codez · 5 weeks ago
  20. 76cd389 [ISSUE #10093] Enhance delayed message type validation in batch send (#10094) by yx9o · 6 weeks ago
  21. a6be1ee [ISSUE # 10086] Fix timer engine switch to persist correct config key (#10085) by liuzhenyu · 6 weeks ago
  22. 35d69cb [ISSUE #10095] Upgraded Commons Lang3 to remediate CVEs (#10096) by shub-est · 6 weeks ago
  23. ec7db8d [ISSUE #10082] Missing PROPERTY_TIMER_DELAY_MS property check in delay message type validation (#10084) by dingshuangxi888 · 6 weeks ago
  24. c197e50 [ISSUE #10079] FlushConsumeQueueService: always flush store checkpoint after CQ flush (#10080) by guyinyou · 6 weeks ago
  25. 1754cec Restore the lost PR 3460 (#10067) by gaoyf · 6 weeks ago
  26. 26480dd [ISSUE #10073] Fix StoreCheckpoint logicsMsgTimestamp to reflect flushed consume queue storetime (#10074) by guyinyou · 6 weeks ago
  27. d254f79 [ISSUE #10071] Fix PopLiteLongPollingService#cleanUnusedResource by Quan · 6 weeks ago
  28. c2c674d [ISSUE #10068] Remove duplicate registration in DefaultMessagingProcessor.init (#10069) by yx9o · 6 weeks ago
  29. 7fe0349 [ISSUE #10063] Notification request adds subscription expression to support on-demand wake-up (#10064) by qianye · 6 weeks ago
  30. a6c5604 [ISSUE #10046] Fix lock leak risk in sendHeartbeatToBroker (#10047) by yx9o · 6 weeks ago
  31. 0471136 [ISSUE #9999] Mark custom delay time messages with delay type (#10000) by yx9o · 6 weeks ago
  32. 10c650c [ISSUE #10034] Optimizing cq iterator and calculating lag (#10056) by lizhimins · 7 weeks ago
  33. 9388842 [ISSUE #9899] Forbid windows sync directory (#10057) by gaoyf · 7 weeks ago
  34. f80753f [ISSUE #10050] Support ChangeInvisibleTime without incrementing message reconsume times (#10051) by ltamber · 7 weeks ago
  35. 7583fda fix(store): close all consume queue file handles on ConsumeQueueStore shutdown (#10060) by rongtong · 7 weeks ago
  36. 89d331c [ISSUE #10054] Correct the output format for ConsumerRecords (#10055) by yx9o · 7 weeks ago
  37. 3a184c3 [ISSUE #10021] Optimize consumer type check with EnumSet (#10022) by yx9o · 7 weeks ago
  38. 24ca9e4 [ISSUE #10043] Make TimerMessageReputService thread pool configurable and shutdown gracefully (#10044) by wizcraft_kris · 7 weeks ago
  39. 9ad4a1b [ISSUE #9988] Remove mismatched response header in getConsumerConnectionList (#9989) by yx9o · 8 weeks ago
  40. c7892a6 [ISSUE #9852] Print full message when CRC not found in properties (#9853) by guyinyou · 8 weeks ago
  41. 90b0906 [ISSUE #10038] Fix checkCommitLogOffsetOnRecover to skip validation for BLANK_MAGIC_CODE messages (#10039) by guyinyou · 8 weeks ago
  42. 50e7ffa [ISSUE #10040] Ignore flattened-pom.xml files generated by maven (#10041) by yx9o · 8 weeks ago
  43. 236ede2 Fix: avoid extra padding when message end position is already page-aligned (#10036) by guyinyou · 9 weeks ago
  44. 4aa6cdd [ISSUE #10019] Revert "[ISSUE #8127]Optimize the metric calculation logic of the time wheel" (#10020) by rongtong · 9 weeks ago
  45. 94ba5e1 [ISSUE #10031] Add PreprocessHandler interface in AllocateMappedFileService by guyinyou · 9 weeks ago
  46. 36adf12 [ISSUE #10017] Validate commitlog offset in recoverAbnormally to prevent processing … (#10018) by guyinyou · 9 weeks ago
  47. 899a1b5 [ISSUE #10023] Remove duplicate shutdown and rejection handler calls for routeThreadPoolExecutor (#10024) by wizcraft_kris · 9 weeks ago
  48. 2eb537c [ISSUE #9980] Skip invalid Pop records when consumer group does not exist (#9982) by Aman Gautam · 9 weeks ago
  49. ee10411 [ISSUE #10015] Optimize writeWithoutMmap. add page alignment to avoid read-modify-write by guyinyou · 9 weeks ago
  50. 1b6a919 [RIP-83] Lite Topic: A New Message Model (#9800) by Quan · 9 weeks ago
  51. 45fc4e0 [ISSUE #10005] Fix switch-case logic in updateConsumerOffsetAsync (#10006) by yx9o · 9 weeks ago
  52. 3d3a2d0 [ISSUE #9975] Bump broker rocksdb from 1.0.2 to 1.0.6 (#10002) by lizhimins · 10 weeks ago
  53. 527bb98 [ISSUE #9900] Supports sending heartbeats to the broker concurrently (#9901) by wizcraft_kris · 10 weeks ago
  54. 500c468 [ISSUE #9978] Remove static from loadJsonConfig and unify exception strings (#9979) by yx9o · 10 weeks ago
  55. b6cc188 [ISSUE #9992] Fix remoting server netty server codec thread reuse problem (#9993) by ymwneu · 10 weeks ago
  56. 4eead13 [ISSUE #9912] Reduce excessive requests for consumer offset timestamps in tiered storage (#9991) by lizhimins · 10 weeks ago
  57. 9fecafe [ISSUE #9953] Fix: there's no need to decompress message body in server side (#9954) by Humkum · 10 weeks ago
  58. ae69814 [ISSUE #9923] Transactional messages should not send custom delayed messages (#9924) by yx9o · 2 months ago
  59. 4c66580 [ISSUE #9994] Improve switchTimerEngine command with OptionGroup validation (#9995) by majialong · 2 months ago
  60. 7fc5452 [ISSUE #9970] Refactor the MessageQueueSelector to support more flexible queue selection strategy (#9971) by qianye · 2 months ago
  61. 9f23894 [ISSUE #9980] Skip invalid records when the group is absent in Pop (#9981) by lizhimins · 2 months ago
  62. 6ab57ad [ISSUE #9976] Update copyright year in NOTICE file to 2026 (#9977) by mxsm · 2 months ago
  63. cbe72c7 [ISSUE #9962] Fix the failure of fastjson2 parsing metricsExporterType in proxy config (#9963) by yuz10 · 2 months ago
  64. 7cc0774 [ISSUE #9964] Rename intConfig method to initConfig (#9965) by yx9o · 3 months ago
  65. 1117ab8 [ISSUE #9780] Skip unnecessary RPC when topic has no message queues (#9781) by yx9o · 3 months ago
  66. b5da00a [ISSUE #9936] Release Apache RocketMQ 5.4.0 (#9937) by lizhimins · 3 months ago release-5.4.0 rocketmq-all-5.4.0
  67. 4b187c6 [ISSUE #9945] Use UniqueKey as the TimerDelKey value when no namespace is appended (#9951) by imzs · 3 months ago
  68. 541fdad [ISSUE #9947] Fix TimerMessageStore.checkAndReviseMetrics throws BufferUnderflowException (#9948) by gaoyf · 3 months ago
  69. 79e7003 [ISSUE #9945] Use UniqueKey as TimerDelKey by default by imzs · 3 months ago
  70. 5132258 Fix epoch truncate (#9942) by littleboy · 3 months ago
  71. fef690c [ISSUE #9943] Remove redundant containsKey check in checkBrokerConfig (#9944) by yx9o · 3 months ago
  72. 684e733 [ISSUE #9938] Rename misnamed Messing classes to Messaging (#9939) by yx9o · 3 months ago
  73. fe5c17c Optimized the function naming (#9935) by Drizzle · 3 months ago
  74. 02412eb [ISSUE #9933] Fix the failure when RocksDBConfigToJsonCommand exports locally. (#9934) by rongtong · 3 months ago
  75. 0792474 [ISSUE #9928] Add Priority IT for GRPC protocol by imzs · 3 months ago
  76. c1ccc3c [ISSUE #9914] Simplify isolation logic when updating fault item in sendKernelImpl (#9915) by yx9o · 3 months ago
  77. 6fa05ff [ISSUE #9921] Limit the concurrency of Pop revive (#9922) by lizhimins · 3 months ago
  78. 8c7bf52 [ISSUE #9902] Remove unnecessary String.format (#9903) by yx9o · 3 months ago
  79. bdae09d [RIP-80] #9928 Implementation of Priority Message (#9929) by imzs · 3 months ago
  80. 9f9cab8 [ISSUE #9396] replace fastjson with fastjson2 (#9927) by yuz10 · 3 months ago
  81. 71659e3 [ISSUE #8903] fix dledger mode expired message can not delete on jdk9+ (#9851) by littleboy · 3 months ago
  82. beee84f [ISSUE #9868] Fix getBrokerEpoch no response issue for empty parameters (#9869) by yx9o · 3 months ago
  83. 15796e7 [ISSUE #9912] Fix consumer offset timestamp displayed incorrect in tiered store (#9913) by SHI · 3 months ago
  84. 6f5b551 [ISSUE #9918] Fix the message may be renewed once more if the gRPC push consumer is unexpectedly disconnected (#9919) by qianye · 3 months ago
  85. 7a08b4c [RIP-82] Implement Timer message, transaction message, and index based on RocksDB (#9787) by Drizzle · 3 months ago
  86. f73fe6c [ISSUE #9885] Fix tiered store cache count and bytes metrics (#9886) by majialong · 3 months ago
  87. 1f387b2 Fix ACL 2.0: correct consumer group extraction from retry topic in SEND_MESSAGE/SEND_MESSAGE_V2/SEND_BATCH_MESSAGE (#9911) by dingshuangxi888 · 3 months ago
  88. 89e021e [ISSUE #9898] Remove AbstractBrokerRunnable and replace with Runnable by rongtong · 4 months ago
  89. 1bb2168 Fix controller mode HAService removeConnection (#9897) by littleboy · 4 months ago
  90. cbfd37b Add some log for gRPC route (#9896) by qianye · 4 months ago
  91. d7e27d6 [ISSUE #9396] Use fastjson2 in all modules (#9397) by yx9o · 4 months ago
  92. 47c6e89 [ISSUE #9894] Update README for RocketMQ 5.3.4 and minor fixes (#9895) by majialong · 4 months ago
  93. 1a3c922 Defer the shutdown behavior of popConsumerService to prevent JVM crash (#9889) by rongtong · 4 months ago
  94. 9f58198 [ISSUE #9883] Remove unnecessary MessageFormat.format (#9884) by yx9o · 4 months ago
  95. bca6393 [ISSUE #9891] Optimize pop orderly implementation to facilitate expansion (#9892) by qianye · 4 months ago
  96. 63d20eb [ISSUE #9734] Set revision to 5.3.4 in maven pom (#9876) by lizhimins · 4 months ago release-5.3.4 rocketmq-all-5.3.4
  97. b77f2ab [ISSUE #9734] Prepare to release Apache RocketMQ 5.3.4 (#9861) by lizhimins · 4 months ago
  98. e87f9cb [ISSUE #9875] Optimize the RocksDB config shutdown logic when useSingleRocksDBForAllConfigs is set to true to prevent JVM crashes. (#9874) by rongtong · 4 months ago
  99. e984023 [ISSUE #9816] Fix calculate consumer lag with opentelemetry (#9873) by lizhimins · 4 months ago
  100. f33f626 [ISSUE #9663] Add flatten-maven-plugin plugin (#9866) by lizhimins · 4 months ago