Commit Graph

  • f96b6314bd [ISSEU #6426] Fix slave broker SubscriptionGroupConfig and MessageRequestMode updating atomically (#8983) Aurora Twinkle 2025-01-13 14:45:20 +08:00
  • e84041d235 [ISSUE #9121] Fix CRC32 Check Failing When Value is 0 guyinyou 2025-01-11 10:27:46 +08:00
  • 034812baa8 [ISSUE #9112] Speedup revive scan in Pop Consumption and support server side reset offset (#9113) lizhimins 2025-01-08 23:00:22 +08:00
  • e02f8e7f32 [ISSUE #9064] Optimize transaction message callback check logic (#9062) LilMosey 2025-01-08 17:25:04 +08:00
  • 7445d9f38b [ISSUE #9108] Refactor ColdDataCgCtrService#getColdDataFlowCtrInfo (#9109) yx9o 2025-01-08 17:14:59 +08:00
  • f096292463 [ISSUE #9105] Fix the issue of duplicate consumption in LMQ (#9101) rongtong 2025-01-06 10:51:58 +08:00
  • 6b820d5638 [ISSUE #8998] No retry is required when the remaining time reaches zero (#8999) hqbfz 2025-01-06 10:23:47 +08:00
  • e14c1b3102 [ISSUE #9106] Fix revive backoff retry not effective in Pop Consumption based on rocksdb (#9107) Liu Shengzhong 2025-01-06 10:03:34 +08:00
  • ebff9bedba [ISSUE #9025] [RIP-73] Modify Pop Consumption rocksdb init config (#9100) lizhimins 2025-01-03 19:39:35 +08:00
  • a80126b078 [ISSUE #9025] [RIP-73] Fix Pop Consumption reset offset (#9087) lizhimins 2024-12-30 20:05:20 +08:00
  • 6e89a85fa6 [ISSUE #9080] Not hold final message store config in fetcher (#9086) lizhimins 2024-12-30 15:21:25 +08:00
  • e091d7d2ee [ISSUE #8974] Add feature switch of recalling, disable by default (#9067) imzs 2024-12-27 13:56:09 +08:00
  • 7a63fde896 [ISSUE #9080] Fix tranfer logic when get large messages from cache in tiered storage (#9079) yuz10 2024-12-26 14:49:00 +08:00
  • dd2288f4b2 [ISSUE #9075]Avoid message type validate in message sync scenario. (#9076) dingshuangxi888 2024-12-25 17:57:47 +08:00
  • 6535e60994 [ISSUE #9069] Fix the IndexFile ConcurrentModificationException in tiered storage (#9071) wangshaojie4039 2024-12-25 17:02:06 +08:00
  • 33810d0549 [ISSUE #8957] Remove excess traffic and fix cache inconsistencies (#8958) hqbfz 2024-12-25 14:38:57 +08:00
  • 2828526218 [ISSUE #9025] [RIP-73] Pop Consumption Improvement Based on RocksDB (#9048) lizhimins 2024-12-20 20:37:25 +08:00
  • a0552fa5df Fix the permission check for retry topic to get topic route. (#9073) dingshuangxi888 2024-12-20 15:39:46 +08:00
  • 89317508cd [ISSUE #9002] when bytebuffer is not enough, do not throw exception (#9003) Lei Zhiyuan 2024-12-19 11:44:32 +08:00
  • e8e900c470 [ISSUE #9054] Optimize log print when client consume message in pop mode (#9055) mxsm 2024-12-15 10:34:08 +08:00
  • 23d1f19db0 [ISSUE #9028] Adjust some error code for SYSTEM_ERROR (#9027) Vincent Lee 2024-12-14 10:08:54 +08:00
  • 42c2949891 [ISSUE #8988] Support dispatchBehindMilliseconds (#8989) guyinyou 2024-12-10 20:05:44 +08:00
  • 7f04b36088 [ISSUE #8970] Remove redundant heartbeats (#8971) weihubeats 2024-12-10 14:54:42 +08:00
  • a3030c8c9b [ISSUE #9021] Correct the error message of acl command (#9022) yx9o 2024-12-10 14:41:07 +08:00
  • d93f16e26c [ISSUE #9042] Update createTimerMessageStore call with new parameter (#9041) 小陈 2024-12-10 14:40:27 +08:00
  • da0ebd7e00 [ISSUE #8974] Support recalling of delay message (#8975) imzs 2024-12-09 16:56:12 +08:00
  • 37a977c2cb reduce duplicate calls (#9037) irotuk 2024-12-09 14:32:37 +08:00
  • 13701a38d0 refactor(LmqBrokerStatsManager): extract common method to eliminate duplicate logic (#9034) asapple 2024-12-07 17:59:46 +08:00
  • 465a326ff6 [ISSUE #8979] Add configurable switch for timer message retry logic (#8980) 小陈 2024-12-05 17:49:03 +08:00
  • d711e4e5c6 [ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of message body (#9016) Zhanhui Li 2024-12-05 15:06:35 +08:00
  • f9d87ce4d7 [ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when the commitlog and consumeQueue are truncated (#7488) rongtong 2024-12-04 15:46:56 +08:00
  • 3788aac213 [ISSUE #9014] Fix clusterAclConfigVersion command execution failed (#9017) yx9o 2024-12-03 09:56:40 +08:00
  • 0604aefa5c [ISSUE #9007] Fix client connection local ip is null in RemotingClient (#9008) weihubeats 2024-12-02 15:13:05 +08:00
  • a1d20d22eb fix: multiple patches during long running tests for LMQ over RocksDB (#8915) Zhanhui Li 2024-12-02 10:07:54 +08:00
  • 33dcf78c47 [ISSUE #8966] Feat: add remote address information to acl perm error Humkum 2024-12-02 10:04:17 +08:00
  • f41e867eca [ISSUE #8950] Remove Redundant nullcheck of configPath (#8951) jiao jianan 2024-12-02 10:03:16 +08:00
  • 970bd5b171 [ISSUE #8984] Fix the broker switch enableMixedMessageType doesn't work Liu Shengzhong 2024-12-02 10:01:51 +08:00
  • ff3855d386 test (#9010) qianye 2024-11-29 17:18:49 +08:00
  • ca389d1b1c [ISSUE #7199] grpcClientChannel header add null judgement (#7238) weihubeats 2024-11-28 18:01:45 +08:00
  • fbe8a5a245 [ISSUE #8991] prepareHeartbeatData should not be set by default subscriptionDataSet data (#8992) weihubeats 2024-11-28 10:31:23 +08:00
  • 6eb4bcfd97 [ISSUE #8968] Introduce the clearRetryTopicWhenDeleteTopic option to enable precise external deletion of topics (#8969) rongtong 2024-11-27 16:19:06 +08:00
  • ebf2a1095f [ISSUE #8963] Fix code36 request sent to ns (#8964) yx9o 2024-11-27 14:43:45 +08:00
  • 3029e548c5 [ISSUE #8976] Modify file segment construct method (#8977) lizhimins 2024-11-26 14:16:38 +08:00
  • e6620aafdf [ISSUE #8982] Dynamically install latest Go version for e2e pipeline (#8985) 小陈 2024-11-26 11:37:46 +08:00
  • 39efe63ce3 [ISSUE #8460] Set default broker name when revive found ack without broker name field (#8981) lizhimins 2024-11-25 19:24:43 +08:00
  • ca2fd11ed4 [ISSUE #8961] Automatic recognition of address scheme in Topic Route by host (#8962) dingshuangxi888 2024-11-22 15:34:36 +08:00
  • 88474e1ada Adding the EnableLmqStats option allows monitoring of LMQ statistics at runtime (#8973) rongtong 2024-11-22 12:57:38 +08:00
  • bfa0c02386 [ISSUE #8955] Fix message buffer not release and dispatch thread exit in tiered storage (#8965) lizhimins 2024-11-22 11:02:50 +08:00
  • aa31fd94be [ISSUE #8877] Refactor lock in ReceiptHandleGroup to make the lock can be properly released when future can not be completed (#8916) qianye 2024-11-21 17:53:46 +08:00
  • 4a123b83f0 [ISSUE #8929] Proxy adds message body empty check when send in grpc protocol (#8930) qianye 2024-11-21 16:40:48 +08:00
  • cb3db08c86 [ISSUE #8933] feat: DefaultPullConsumer add balance switch (#8934) Humkum 2024-11-20 14:58:30 +08:00
  • 14e98fb7ca [ISSUE #8947] Notify pop request before calculate consumer lag (#8949) lizhimins 2024-11-20 14:57:35 +08:00
  • 64526d2a5c fix: avoid memory overhead when there is large number of LMQ ConsumeQueue (#8956) Zhanhui Li 2024-11-20 14:55:30 +08:00
  • 3eba29a618 Improve IO for asynchronous delivery processes (#8954) hqbfz 2024-11-20 11:13:12 +08:00
  • 33c6918f18 [ISSUE #8765] fix low performance of delay message when enable rocksdb consume queue (#8766) yuz10 2024-11-20 11:10:01 +08:00
  • df0a474cc6 [ISSUE #8935] Fix behind metrics unit error in timer message store (#8936) Ji Juntao 2024-11-19 17:35:10 +08:00
  • 03fe4a5021 Fix incorrect path for exportMetadataInRocksDBCommand (#8941) rongtong 2024-11-18 17:25:20 +08:00
  • 9feedcf7a6 [ISSUE #8945] Remove unnecessary operations from the critical section hqbfz 2024-11-18 16:46:34 +08:00
  • 8f47bbe854 Support for Persisting LMQ Consumer Offsets in Config V1 Using RocksDB (#8939) rongtong 2024-11-18 14:30:01 +08:00
  • 297e40e89b Add incGroupAckNums and incGroupCkNums to LmqBrokerStatsManager (#8943) rongtong 2024-11-18 14:23:00 +08:00
  • 325f465323 [ISSUE #8901] Add more test coverage for RpcClientImpl (#8902) yx9o 2024-11-18 10:19:48 +08:00
  • 461d2c8f6c [ISSUE #8909] Move nullcheck ahead (#8910) jiao jianan 2024-11-16 09:07:55 +08:00
  • 0b557ed896 fix update user not valid bug (#8926) dingshuangxi888 2024-11-15 10:35:37 +08:00
  • 58c8f9987f [ISSUE #8921] Add isWakeCommitWhenPutMessage for AIO Drizzle 2024-11-14 19:42:25 +08:00
  • 1d9de8acdf [ISSUE #8917]Topic route return none permission message queues for gRPC client (#8919) dingshuangxi888 2024-11-14 19:24:19 +08:00
  • 70f9a8d587 close channel when receive go away twice (#8862) qianye 2024-11-14 14:07:20 +08:00
  • 24acd042d9 [ISSUE #8906] Handle string toUpperCase outside the loop mawen12 2024-11-12 19:29:21 +08:00
  • 6e80144ab6 fixed typo of RocketMQ_Example.md (#8905) TianMing2018 2024-11-11 10:00:26 +08:00
  • b2e333a8fa [ISSUE #8889] handle namespace outside the loop (#8890) mawen12 2024-11-08 09:03:10 +08:00
  • 85c3d7f9d5 [ISSUE #8882] Change the compare method for acl signature to improve the security. (#8883) dingshuangxi888 2024-11-07 19:04:54 +08:00
  • a4432501f0 [ISSUE #8808] Resolve unsupported 'UseBiasedLocking' VM Option for JDK21 (#8809) Thomas Lee 2024-11-06 19:30:18 +08:00
  • c81105e72f [ISSUE #8885] Resolve the issue of inaccurate CK number statistics (#8886) rongtong 2024-11-06 10:15:42 +08:00
  • 7db3b1ba71 [ISSUE #8829] Keep data version while reload and XXXConfigManagerV2 turns off sync Zhanhui Li 2024-11-06 10:12:24 +08:00
  • 9e15ecf447 [ISSUE #8725] clean DefaultMQPushConsumer after start fail (#8726) yuz10 2024-10-30 20:08:28 +08:00
  • 014350c74f [ISSUE #8875] Fix HAConnection leak Crazywen 2024-10-30 16:42:30 +08:00
  • ba394f98d0 Revert "fix RequestCode overflowed issues:8868 (#8871)" (#8874) Zhanhui Li 2024-10-30 14:20:00 +08:00
  • f662835ae5 [ISSUE #8892] Add test cases to config manager v2 (#8873) Zhanhui Li 2024-10-29 20:07:49 +08:00
  • 03f39868cf fix RequestCode overflowed issues:8868 (#8871) zzjcool 2024-10-29 19:44:20 +08:00
  • ad92374a32 [ISSUE #8822] Double write cq, reduce unnecessary switches (#8823) LetLetMe 2024-10-29 19:09:35 +08:00
  • 5df17c515f update LanguageCode (#8872) zhaohai 2024-10-29 19:07:14 +08:00
  • 61df66b7f9 [ISSUE #8852] Add more test coverage for ClientMetadata (#8853) yx9o 2024-10-28 16:32:58 +08:00
  • 7f1d7fb367 [ISSUE #8829] feat: provide ConfigManagerV2 to make best uses of RocksDB (#8856) Zhanhui Li 2024-10-28 10:00:33 +08:00
  • 43b9809bf0 [ISSUE #8442][RIP-70-3] Extract adaptive lock mechanism (#8663) hqbfz 2024-10-23 19:17:37 +08:00
  • 9db5a2d405 [ISSUE #8829]feat: add test case to RocksDBConsumeQueueOffsetTable (#8857) Zhanhui Li 2024-10-23 19:17:05 +08:00
  • d8c99a48cf [ISSUE #8772] Remove lock mq step in broadcasting mode rebalancing (#8774) Liu Shengzhong 2024-10-23 10:29:56 +08:00
  • 6f41c3966e use correct log method (#8851) mawen12 2024-10-23 09:57:35 +08:00
  • e7a9bc2803 Support LMQ dispatch in case if Consume Queue Store is RocksDB-based (#8842) Zhanhui Li 2024-10-23 09:56:37 +08:00
  • cb80538c61 fix: registerProducer should not be affected by concurrent scanNotAct… (#8847) Zhanhui Li 2024-10-23 09:37:17 +08:00
  • 51fa4ee559 [ISSUE #8848] Fix log typo mawen12 2024-10-23 08:29:35 +08:00
  • 7bc2d92afc update netty version to 4.1.114 to fix CVE-2023-34462 (#8832) dinglei 2024-10-21 13:40:49 +08:00
  • 7666e474d4 fix: remove unnecessary synchronized to improve concurrency (#8840) Zhanhui Li 2024-10-21 09:25:55 +08:00
  • 3ec1263de4 fix: make ConsumeQueueStore bottom most compression type configurable (#8841) Zhanhui Li 2024-10-18 16:50:13 +08:00
  • 429379983d fix: atomic flush incorrect use and clean up code (#8830) Zhanhui Li 2024-10-18 14:30:38 +08:00
  • c6f21ca149 fix variables match annotation (@RocketMQResource) (#8821) mawen12 2024-10-18 09:18:41 +08:00
  • 1e3bfe0b0f [ISSUE #8835] When ck is in the buffer, incomplete ack will lead to message duplication. (#8836) Ji Juntao 2024-10-17 19:16:14 +08:00
  • 20437402fd [ISSUE #8780] Implement asynchronous storage of ack/ck messages in pop consume to enhance performance (#8727) rongtong 2024-10-16 13:39:27 +08:00
  • f08eeb8342 [ISSUE #8824] Fix IllegalStateException caused by logical errors (#8825) yx9o 2024-10-16 11:00:51 +08:00
  • fa4f33a8c4 [ISSUE #8764] Implement consume lag estimation in cq rocksdb store (#8800) LetLetMe 2024-10-15 14:14:31 +08:00
  • cb1e1cbf97 [ISSUE #8816] Fix log typo. (#8817) luozongle01 2024-10-14 09:13:17 +08:00
  • c68bc66dd6 [ISSUE #8810] Fix independent execution of e2e and benchmark deployments (#8812) 小陈 2024-10-11 16:43:07 +08:00