Commit Graph

  • 29546558d2 [ISSUE #9652] Enhance test for MQClientInstance (#9653) Duxuwei 2025-09-01 17:55:23 +08:00
  • 40437ae63e Bump io.grpc:grpc-protobuf from 1.53.0 to 1.54.2 dependabot/maven/io.grpc-grpc-protobuf-1.54.2 dependabot[bot] 2025-08-25 03:36:43 +00:00
  • 7ab7ddd6d2 [ISSUE #9609] Fix bazel CI and reduce dependencies (#9610) Hongxu Xu 2025-08-22 04:35:39 -04:00
  • e6a587a82a [ISSUE #9626] Prevent premature offset commit before consumer record flush (#9627) lizhimins 2025-08-22 14:43:50 +08:00
  • f40a69f9f1 fix: remove wrong logic in the callback for sending messages in rpc (#9608) hqbfz 2025-08-12 18:51:35 +08:00
  • c05dcdc155 [ISSUE #9611] Should exec callback in the Pop based on rocksdb impl (#9612) lizhimins 2025-08-12 16:58:22 +08:00
  • 9e2445ee9a [ISSUE #9589] Optimize broker metrics initialization (#9598) qianye 2025-08-12 14:23:00 +08:00
  • 6d4fb83577 [ISSUE #9605] Fixed a potential resource leak (#9606) Xiao Yang 2025-08-09 15:45:35 +08:00
  • 960972237f [ISSUE #9596] Optimize log in invokeSync when addr is null (#9597) ccwss 2025-08-06 15:33:50 +08:00
  • f798f96df1 [ISSUE #9254] Optimize innerConsumeQueueStoreList order in CombineConsumeQueueStore qianye 2025-08-06 10:03:31 +08:00
  • 2791833b91 Fix typos (#9560) co63oc 2025-07-28 20:13:25 +08:00
  • 100f467f6c [ISSUE #9572] Unnecessary code comment cleanup (#9573) Xiao Yang 2025-07-28 10:05:54 +08:00
  • e20d56b9bd [ISSUE #9254] Refactor notifyMessageArriveInBatch in RocksDBConsumeQueueStore to adapt to CombineConsumeQueueStore (#9566) qianye 2025-07-23 16:11:56 +08:00
  • 438077e7ad Limit group max length to 120. (#9563) Jixiang Jin 2025-07-22 17:51:50 +08:00
  • 40e3aa938f [ISSUE #9553] Improve performance by avoiding repeated get(key) (#9554) Xiao Yang 2025-07-20 10:05:52 +08:00
  • 2238256de1 [maven-release-plugin] prepare release rocketmq-all-5.3.3 (#9388) master lizhimins 2025-05-07 09:48:32 +08:00
  • d26ecd0ded [ISSUE #9381] Prepare to release Apache RocketMQ 5.3.3 (#9385) lizhimins 2025-05-06 18:54:03 +08:00
  • 2f384c9b5f Revert "[ISSUE# 9333] Use fastjson2 in broker module (#9334)" (#9387) lizhimins 2025-05-06 17:55:53 +08:00
  • 677a0f5810 Revert "[ISSUE #9188] Use fastjson2 in org/apache/rocketmq/broker/config/v1 (…" (#9386) lizhimins 2025-05-06 17:55:05 +08:00
  • 49be182adf [ISSUE #9379] Fix timeStoreTable delete logic in IndexService (#9384) lizhimins 2025-05-06 15:31:03 +08:00
  • 15eb188316 [ISSUE #9377] fix 'send trace data can fail if shutdown producer immediately' (#9378) kaikoo 2025-04-30 15:15:59 +08:00
  • f75dc5a4d2 [ISSUE 9362] [RIP-77] Deprecate and Remove ACL 1.0 (#9363) dingshuangxi888 2025-04-30 15:02:55 +08:00
  • 50160bfdea [ISSUE #9375] Make client trace thread can be closed correctly (#9376) qianye 2025-04-30 10:27:18 +08:00
  • be73bf705a [ISSUE #9233] Fix query time boundary calculation in tiered storage (#9374) dingshuangxi888 2025-04-29 19:41:05 +08:00
  • 26bfbe6a28 [ISSUE #9371] Delete ConsumeQueue index before CommitLog in tiered storage (#9372) lizhimins 2025-04-29 10:31:49 +08:00
  • a867938849 [ISSUE #9369] Fix reset offset commit pull offset when use pop consumer service (#9370) lizhimins 2025-04-28 14:02:22 +08:00
  • 34742b968a [ISSUE #9313] Add scheduled clean task. (#9314) Ji Juntao 2025-04-25 17:46:30 +08:00
  • 77c1ba4f50 [ISSUE #9351] Add topic-group mapping in queryTopicConsumeByWho command (#9352) yangguodong 2025-04-23 13:51:01 +08:00
  • fb848dbc2d [ISSUE #9360] Fix some services are not shutdown when the broker offline (#9361) lizhimins 2025-04-23 13:50:08 +08:00
  • 9228e74c0c [ISSUE #9358] Timediff should multiply 1000 when query message from tiered storage (#9359) bxfjb 2025-04-23 10:33:49 +08:00
  • 1e07aa514f [ISSUE# 9333] Use fastjson2 in broker module (#9334) yx9o 2025-04-22 10:48:56 +08:00
  • 50ff54c462 [ISSUE #9339] Fix pop update consumption offset when message are filtered (#9340) lizhimins 2025-04-16 16:00:37 +08:00
  • 3cd0290714 Make sure to create system topics to all the brokers in ‘systemTopicClusterName’ cluster. (#9327) Jixiang Jin 2025-04-16 15:30:55 +08:00
  • 3f00836995 [ISSUE #9331] Found one info log lose parameters during proxy startup (#9332) WJ66880 2025-04-16 11:25:02 +08:00
  • 6056479b57 [ISSUE #9288] Support the disablement of producer registration and fast channel shutdown (#9293) ymwneu 2025-04-11 15:45:00 +08:00
  • b277dc82fa [ISSUE #9115] Optimize the broker's reverse notification for consumerId change (#9116) yx9o 2025-04-11 15:38:07 +08:00
  • 0cb6b45918 [ISSUE #9294] Proxy compatible batch message (#9295) gaoyf 2025-04-11 14:37:54 +08:00
  • 47fe25f608 [ISSUE #9188] Use fastjson2 in org/apache/rocketmq/broker/config/v1 (#9189) yx9o 2025-04-11 14:24:25 +08:00
  • a3a81d5076 Optimize the log output of tlsHelper (#9324) rongtong 2025-04-11 14:21:48 +08:00
  • 4fe3613d14 [ISSUE #9302] SendMessageContext add message type (#9303) ymwneu 2025-04-09 15:39:24 +08:00
  • 1eeb4574e1 [ISSUE #1918] Catch throwable in PullMessageService thread run method (#9278) fuyou001 2025-04-04 14:56:00 +08:00
  • 1134417c78 [ISSUE #9297] Supports outputting topic put TPS in TopicStatusSubCommand (#9298) ymwneu 2025-04-02 18:59:45 +08:00
  • 1cf84413bc Avoid NPE for handling client settings null in notifyClientTermination. (#9308) Jixiang Jin 2025-04-02 18:54:07 +08:00
  • 44a51e8e1e [ISSUE #9279] Restrict system subscription group creation and add pull request rejection policy (#9280) ymwneu 2025-04-01 17:12:36 +08:00
  • 3c679716b6 [ISSUE #9284] When pullMessage overflow one, should refresh recordDiskFallBehind data (#9285) ymwneu 2025-04-01 13:52:26 +08:00
  • e9dc679d83 [ISSUE #9286] Counting the filtered message when filter by SQL92 (#9287) ymwneu 2025-04-01 13:48:04 +08:00
  • dd8eb7c88f [ISSUE #9300] Periodic cleanup of inactive items in StatsItemSet (#9301) ymwneu 2025-04-01 13:43:56 +08:00
  • f818df501c [ISSUE #9304] Resolve cold data read control issue in DefaultMessageStore (#9305) ymwneu 2025-04-01 13:38:46 +08:00
  • dd1d5b99e0 [ISSUE #9282] Optimize BrokerController#printWaterMark (#9283) yx9o 2025-03-31 10:49:24 +08:00
  • 107341eacf [ISSUE #9271] Enhance tiered storage getQueueOffsetByTimeAsync (#9272) bxfjb 2025-03-27 13:57:47 +08:00
  • 0f75753c4c [ISSUE #7948] Prevent invoking the queryMessage method lead to OOM (#9265) half 2025-03-26 10:31:02 +08:00
  • 57a098e5a7 [ISSUE #9266] Updated the Quick Start version in README to the latest version (#9267) yx9o 2025-03-22 16:54:43 +08:00
  • 834f8a8761 [ISSUE #9259] Remove duplicate flushing operation of StoreCheckpoint(#9260) mxsm 2025-03-20 11:44:03 +08:00
  • f5686f1c48 [ISSUE #8243] Update Configuration Docs for RocketMQ 5.x Compatibility (#9258) DivyanshIITB 2025-03-20 09:11:10 +05:30
  • cf2e973957 [ISSUE #8701] Fix documentation for brokerAddrTable property in MQClientInstance.java (#9263) DivyanshIITB 2025-03-20 08:44:30 +05:30
  • d07a946749 [ISSUE #9244] Avoid writing dirty data in consumption mode (#9245) hqbfz 2025-03-17 17:32:41 +08:00
  • 671a090d16 [ISSUE #9241] RocksDBConsumeQueueStore do not need to update StoreCheckpoint (#9242) qianye 2025-03-17 17:30:48 +08:00
  • 4f89e46e60 [ISSUE #9249] When delivery fails, there is an incorrect start offset in the delivery settings Liu JinJie 2025-03-17 15:49:24 +08:00
  • e89dfdbcf5 Fix unstable test: BrokerOuterAPITest.test_needRegister_timeout (#9250) DivyanshIITB 2025-03-17 11:51:11 +05:30
  • 0a21046be8 [ISSUE #9246] Support init offset mode in PopConsumerService (#9247) lizhimins 2025-03-15 15:02:06 +08:00
  • 534add8a40 [ISSUE #9233] Query message in tiered storage may fail for the first correct index file was not selected (#9234) bxfjb 2025-03-13 17:02:58 +08:00
  • dd2de49f25 Update NOTICE (#9238) Jannis Klose 2025-03-13 08:57:44 +01:00
  • 4ac634e446 [ISSUE #8997] Ensure there is an opportunity to send a retry message when broker no response (#9137) gaoyf 2025-03-10 16:03:10 +08:00
  • 29e38a59a8 [maven-release-plugin] prepare for next development iteration (#9232) lizhimins 2025-03-08 17:20:49 +08:00
  • 33f378ad36 [maven-release-plugin] prepare release rocketmq-all-5.3.2 (#9231) lizhimins 2025-03-08 14:07:17 +08:00
  • c037d2d211 [ISSUE #9227] Prepare to release Apache RocketMQ 5.3.2 (#9228) lizhimins 2025-03-07 15:45:26 +08:00
  • a2f11d3f49 [ISSUE #9223] Pop consumer example add the default NamesrvAddr (#9224) hqbfz 2025-03-07 13:47:35 +08:00
  • c0f7766589 [ISSUE #9184] Optimize QueueLockManager#tryLock method (#9185) mxsm 2025-03-07 13:46:52 +08:00
  • bd8a620f3b [ISSUE #8127] Optimize the metric calculation logic of the time wheel (#8128) hqbfz 2025-03-04 15:53:28 +08:00
  • fd6c24a4ac [ISSUE #9221] Extract some common code in BrokerPathConfigHelper (#9222) yx9o 2025-03-04 15:20:28 +08:00
  • 58d169f397 [ISSUE #9217] Fix broker's inflight and available message counts incorrect when the pop consumer service is enabled (#9218) lizhimins 2025-03-03 14:24:02 +08:00
  • 179699ac02 [ISSUE #9196] Broker return pop stats when receive notification (#9197) qianye 2025-03-03 11:35:03 +08:00
  • 1e5232d40d [ISSUE #9213] Fix get the earliest time error when data is clean up in tiered storage (#9214) lizhimins 2025-03-03 09:58:06 +08:00
  • 7f80aeaaec Optimize RocksDB CQ shutdown when using DoubleWriteCQ #9212 qianye 2025-02-28 14:19:38 +08:00
  • f657bf2ceb Revert "[ISSUE #9176] Fix pop message header missing fields when enable ACL 2…" (#9211) lizhimins 2025-02-28 09:52:46 +08:00
  • a955ce4b77 [ISSUE #8340] RuntimeInfo and ClusterListSubCommand show ackThreadPoolQueueSize and ackThreadPoolQueueHeadWaitTimeMills (#8339) rongtong 2025-02-26 15:29:55 +08:00
  • e0580bcd3f [ISSUE #9206] Fix slave sync topic sub in rocksdb ha (#9207) fujian-zfj 2025-02-26 11:27:40 +08:00
  • 137e7bf17b [ISSUE #9203] Replace numbers with static variables defined in RequestCode 阿洋 2025-02-25 08:09:53 +08:00
  • adf2c4d651 [ISSUE #9191] Provide the ability to replace the remoting layer implementation for Proxy and Broker (#9192) Quan 2025-02-24 12:27:30 +08:00
  • e441f8deff [ISSUE #9201] cleanup dead code patterns and improve readability and maintainability Kris20030907 2025-02-24 08:44:35 +08:00
  • 822a20d76f [ISSUE #9176] Fix pop message header missing fields when enable ACL 2.0 (#9179) zzl 2025-02-21 14:17:03 +08:00
  • 4771b8bf15 [ISSUE #9187] The request should be rejected if the queueOffset equals maxOffset when changing the invisible time (#9186) rongtong 2025-02-19 17:24:50 +08:00
  • 9abdc3a3de [ISSUE #9182] Fix NameServer will be not ready forever when set needWaitForService to true (#9183) gaoyf 2025-02-17 11:38:51 +08:00
  • 6de9bcaeaa [ISSUE #9181] update fastjson version ltamber 2025-02-13 10:04:51 +08:00
  • df8cf98387 [ISSUE #9172] Clean pull offset and reset offset when delete subscription group (#9173) lizhimins 2025-02-12 19:09:55 +08:00
  • f5c84deeed [ISSUE #9177] Fix unstable tests in AdaptiveLockTest.testAdaptiveLock (#9178) hqbfz 2025-02-12 16:44:34 +08:00
  • 3080771fe0 [ISSUE #9174] Add a collection of predefined Groups and common checking methods in the MixAll (#9175) ltamber 2025-02-12 15:38:42 +08:00
  • 1a114e77f0 [ISSUE #9156] Use fastjson2 in AclUtils#getAclRPCHook (#9157) yx9o 2025-02-10 10:40:59 +08:00
  • 02d28c5f43 Restrict the list version workflow to be executed only in the main repository (#9168) totalo 2025-02-10 08:28:39 +08:00
  • 4f2e0773fb [ISSUE #9149]Assign offset in offsetTable even if the subscription key not exist. (#9150) dingshuangxi888 2025-02-06 16:48:31 +08:00
  • af5ebb150d [ISSUE #9152] Broker getConsumeStats supports inputting multiple topics (#9153) qianye 2025-02-05 14:41:53 +08:00
  • 13af9a060d [ISSUE #9155] Update doc Deployment Context Lynx 2025-01-28 10:08:32 +08:00
  • 9003b47e53 [ISSUE#9160] Ensure the requestCode increments sequentially Matthew 2025-01-28 10:08:00 +08:00
  • 99cd998c84 [ISSUE #9119] Invoke async should throw raw exception instead of CompletionException (#9120) gaoyf 2025-01-17 11:44:32 +08:00
  • 18a69d5169 [ISSUE #8728] Add more test coverage for TopicQueueMappingCleanService (#8729) yx9o 2025-01-16 13:54:04 +08:00
  • 5d008d38fa fix(comment): correct typos in ConsumeQueueExt class. (#9124) Kris20030907 2025-01-15 14:51:09 +08:00
  • 2bf15c3650 [ISSUE #4570] fix: Docker usage may occur error in volume mapping params, simple fix (#9096) Jax 2025-01-14 20:22:30 +08:00
  • bfaf5cd8de [ISSUE #9128] Fix NPE when grpc client ack message immediately after changing proxy (#9129) qianye 2025-01-14 16:01:28 +08:00
  • d1dd9d7e16 [ISSUE #8895] Fix NPE when broker shutdown and optimize the log #9094 qianye 2025-01-14 14:50:56 +08:00
  • ae8dfc3457 [ISSUE #9111] Support export broker RocksDB Config to json file (#9114) qianye 2025-01-14 10:29:40 +08:00