Commit Graph

  • 2089abd3be [ISSUE #9080] Fix tranfer logic when get large messages from cache in tiered storage (#9079) yuz10 2024-12-26 14:49:00 +08:00
  • 1c35adb3dc [ISSUE #9075]Avoid message type validate in message sync scenario. (#9076) dingshuangxi888 2024-12-25 17:57:47 +08:00
  • 152a955ca4 [ISSUE #9069] Fix the IndexFile ConcurrentModificationException in tiered storage (#9071) wangshaojie4039 2024-12-25 17:02:06 +08:00
  • d63373a152 [ISSUE #8957] Remove excess traffic and fix cache inconsistencies (#8958) hqbfz 2024-12-25 14:38:57 +08:00
  • 35a6426ea9 [ISSUE #9025] [RIP-73] Pop Consumption Improvement Based on RocksDB (#9048) lizhimins 2024-12-20 20:37:25 +08:00
  • 91fdc35db3 Fix the permission check for retry topic to get topic route. (#9073) dingshuangxi888 2024-12-20 15:39:46 +08:00
  • 16b6e53263 [ISSUE #9002] when bytebuffer is not enough, do not throw exception (#9003) Lei Zhiyuan 2024-12-19 11:44:32 +08:00
  • 93e268909c [ISSUE #9054] Optimize log print when client consume message in pop mode (#9055) mxsm 2024-12-15 10:34:08 +08:00
  • b5cf3ca90a [ISSUE #9028] Adjust some error code for SYSTEM_ERROR (#9027) Vincent Lee 2024-12-14 10:08:54 +08:00
  • 9aa081b8ac [ISSUE #8988] Support dispatchBehindMilliseconds (#8989) guyinyou 2024-12-10 20:05:44 +08:00
  • 564e55ea58 [ISSUE #8970] Remove redundant heartbeats (#8971) weihubeats 2024-12-10 14:54:42 +08:00
  • 9834691b73 [ISSUE #9021] Correct the error message of acl command (#9022) yx9o 2024-12-10 14:41:07 +08:00
  • 7da9ad4fa5 [ISSUE #9042] Update createTimerMessageStore call with new parameter (#9041) 小陈 2024-12-10 14:40:27 +08:00
  • bfb3d17ef1 [ISSUE #8974] Support recalling of delay message (#8975) imzs 2024-12-09 16:56:12 +08:00
  • 4571a853a2 reduce duplicate calls (#9037) irotuk 2024-12-09 14:32:37 +08:00
  • 4ea8d1ff6c refactor(LmqBrokerStatsManager): extract common method to eliminate duplicate logic (#9034) asapple 2024-12-07 17:59:46 +08:00
  • d1fd7af3f1 [ISSUE #8979] Add configurable switch for timer message retry logic (#8980) 小陈 2024-12-05 17:49:03 +08:00
  • 01a51231b3 [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
  • f4c498433d [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
  • e104c02d50 [ISSUE #9014] Fix clusterAclConfigVersion command execution failed (#9017) yx9o 2024-12-03 09:56:40 +08:00
  • 99960eab26 Bump org.springframework:spring-core from 5.3.27 to 6.1.14 dependabot/maven/org.springframework-spring-core-6.1.14 dependabot[bot] 2024-12-02 21:34:31 +00:00
  • 78501c7461 [ISSUE #9007] Fix client connection local ip is null in RemotingClient (#9008) weihubeats 2024-12-02 15:13:05 +08:00
  • 9a891f1d49 fix: multiple patches during long running tests for LMQ over RocksDB (#8915) Zhanhui Li 2024-12-02 10:07:54 +08:00
  • ea1228a30a [ISSUE #8966] Feat: add remote address information to acl perm error Humkum 2024-12-02 10:04:17 +08:00
  • 93d7e80a97 [ISSUE #8950] Remove Redundant nullcheck of configPath (#8951) jiao jianan 2024-12-02 10:03:16 +08:00
  • fb3b87da1b [ISSUE #8984] Fix the broker switch enableMixedMessageType doesn't work Liu Shengzhong 2024-12-02 10:01:51 +08:00
  • 804847e877 test (#9010) qianye 2024-11-29 17:18:49 +08:00
  • d2c436b7fb [ISSUE #7199] grpcClientChannel header add null judgement (#7238) weihubeats 2024-11-28 18:01:45 +08:00
  • adc1c748ef [ISSUE #8991] prepareHeartbeatData should not be set by default subscriptionDataSet data (#8992) weihubeats 2024-11-28 10:31:23 +08:00
  • 3ae0139aa0 [ISSUE #8968] Introduce the clearRetryTopicWhenDeleteTopic option to enable precise external deletion of topics (#8969) rongtong 2024-11-27 16:19:06 +08:00
  • cd5071bd05 [ISSUE #8963] Fix code36 request sent to ns (#8964) yx9o 2024-11-27 14:43:45 +08:00
  • fc2283008b [ISSUE #8976] Modify file segment construct method (#8977) lizhimins 2024-11-26 14:16:38 +08:00
  • a2eafb2ad5 [ISSUE #8982] Dynamically install latest Go version for e2e pipeline (#8985) 小陈 2024-11-26 11:37:46 +08:00
  • b638d4cfbb [ISSUE #8460] Set default broker name when revive found ack without broker name field (#8981) lizhimins 2024-11-25 19:24:43 +08:00
  • a8779c0d4e [ISSUE #8961] Automatic recognition of address scheme in Topic Route by host (#8962) dingshuangxi888 2024-11-22 15:34:36 +08:00
  • 715dd5a885 Adding the EnableLmqStats option allows monitoring of LMQ statistics at runtime (#8973) rongtong 2024-11-22 12:57:38 +08:00
  • e876bed084 [ISSUE #8955] Fix message buffer not release and dispatch thread exit in tiered storage (#8965) lizhimins 2024-11-22 11:02:50 +08:00
  • 5f2642391d [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
  • 796c95b928 [ISSUE #8929] Proxy adds message body empty check when send in grpc protocol (#8930) qianye 2024-11-21 16:40:48 +08:00
  • 9202de34c3 [ISSUE #8933] feat: DefaultPullConsumer add balance switch (#8934) Humkum 2024-11-20 14:58:30 +08:00
  • 23cc24cc6e [ISSUE #8947] Notify pop request before calculate consumer lag (#8949) lizhimins 2024-11-20 14:57:35 +08:00
  • 8505482c0b fix: avoid memory overhead when there is large number of LMQ ConsumeQueue (#8956) Zhanhui Li 2024-11-20 14:55:30 +08:00
  • c13f051eb8 Improve IO for asynchronous delivery processes (#8954) hqbfz 2024-11-20 11:13:12 +08:00
  • ae7179d75e [ISSUE #8765] fix low performance of delay message when enable rocksdb consume queue (#8766) yuz10 2024-11-20 11:10:01 +08:00
  • 78575af0b8 [ISSUE #8935] Fix behind metrics unit error in timer message store (#8936) Ji Juntao 2024-11-19 17:35:10 +08:00
  • bf2f2a7774 Fix incorrect path for exportMetadataInRocksDBCommand (#8941) rongtong 2024-11-18 17:25:20 +08:00
  • c961edd2fd [ISSUE #8945] Remove unnecessary operations from the critical section hqbfz 2024-11-18 16:46:34 +08:00
  • 163451ed30 Support for Persisting LMQ Consumer Offsets in Config V1 Using RocksDB (#8939) rongtong 2024-11-18 14:30:01 +08:00
  • 4e8a5ca48f Add incGroupAckNums and incGroupCkNums to LmqBrokerStatsManager (#8943) rongtong 2024-11-18 14:23:00 +08:00
  • 2e1ca053d2 [ISSUE #8901] Add more test coverage for RpcClientImpl (#8902) yx9o 2024-11-18 10:19:48 +08:00
  • 4574647a3a [ISSUE #8909] Move nullcheck ahead (#8910) jiao jianan 2024-11-16 09:07:55 +08:00
  • 797024f3f8 fix update user not valid bug (#8926) dingshuangxi888 2024-11-15 10:35:37 +08:00
  • 60e68dadd9 [ISSUE #8921] Add isWakeCommitWhenPutMessage for AIO Drizzle 2024-11-14 19:42:25 +08:00
  • 87b97f271c [ISSUE #8917]Topic route return none permission message queues for gRPC client (#8919) dingshuangxi888 2024-11-14 19:24:19 +08:00
  • 66ba4566f5 close channel when receive go away twice (#8862) qianye 2024-11-14 14:07:20 +08:00
  • 2bbc852361 [ISSUE #8906] Handle string toUpperCase outside the loop mawen12 2024-11-12 19:29:21 +08:00
  • 7eb16fffec fixed typo of RocketMQ_Example.md (#8905) TianMing2018 2024-11-11 10:00:26 +08:00
  • dbd2791eca [ISSUE #8889] handle namespace outside the loop (#8890) mawen12 2024-11-08 09:03:10 +08:00
  • 851473443e [ISSUE #8882] Change the compare method for acl signature to improve the security. (#8883) dingshuangxi888 2024-11-07 19:04:54 +08:00
  • e281697b8e [ISSUE #8808] Resolve unsupported 'UseBiasedLocking' VM Option for JDK21 (#8809) Thomas Lee 2024-11-06 19:30:18 +08:00
  • 43f3c2b61b [ISSUE #8885] Resolve the issue of inaccurate CK number statistics (#8886) rongtong 2024-11-06 10:15:42 +08:00
  • 311b831c02 [ISSUE #8829] Keep data version while reload and XXXConfigManagerV2 turns off sync Zhanhui Li 2024-11-06 10:12:24 +08:00
  • 5600684eb4 [ISSUE #8725] clean DefaultMQPushConsumer after start fail (#8726) yuz10 2024-10-30 20:08:28 +08:00
  • fe8077250b [ISSUE #8875] Fix HAConnection leak Crazywen 2024-10-30 16:42:30 +08:00
  • b974362b37 Revert "fix RequestCode overflowed issues:8868 (#8871)" (#8874) Zhanhui Li 2024-10-30 14:20:00 +08:00
  • dd62ed0f3b [ISSUE #8892] Add test cases to config manager v2 (#8873) Zhanhui Li 2024-10-29 20:07:49 +08:00
  • 327abe5d6e fix RequestCode overflowed issues:8868 (#8871) zzjcool 2024-10-29 19:44:20 +08:00
  • 0b24768500 [ISSUE #8822] Double write cq, reduce unnecessary switches (#8823) LetLetMe 2024-10-29 19:09:35 +08:00
  • a96a14f734 update LanguageCode (#8872) zhaohai 2024-10-29 19:07:14 +08:00
  • ecb45bb90d [ISSUE #8852] Add more test coverage for ClientMetadata (#8853) yx9o 2024-10-28 16:32:58 +08:00
  • c8938e0c6c [ISSUE #8829] feat: provide ConfigManagerV2 to make best uses of RocksDB (#8856) Zhanhui Li 2024-10-28 10:00:33 +08:00
  • 95b88ff8fc [ISSUE #8442][RIP-70-3] Extract adaptive lock mechanism (#8663) hqbfz 2024-10-23 19:17:37 +08:00
  • 738c9f3a95 [ISSUE #8829]feat: add test case to RocksDBConsumeQueueOffsetTable (#8857) Zhanhui Li 2024-10-23 19:17:05 +08:00
  • 2956f6d46b [ISSUE #8772] Remove lock mq step in broadcasting mode rebalancing (#8774) Liu Shengzhong 2024-10-23 10:29:56 +08:00
  • 7f8667adde use correct log method (#8851) mawen12 2024-10-23 09:57:35 +08:00
  • b86059c7c1 Support LMQ dispatch in case if Consume Queue Store is RocksDB-based (#8842) Zhanhui Li 2024-10-23 09:56:37 +08:00
  • d2fd068be7 fix: registerProducer should not be affected by concurrent scanNotAct… (#8847) Zhanhui Li 2024-10-23 09:37:17 +08:00
  • c033c3e85f [ISSUE #8848] Fix log typo mawen12 2024-10-23 08:29:35 +08:00
  • a024dc81da update netty version to 4.1.114 to fix CVE-2023-34462 (#8832) dinglei 2024-10-21 13:40:49 +08:00
  • e8a9d9ffd0 update netty version to 4.1.114 to fix CVE-2023-34462 (#8834) dinglei 2024-10-21 13:37:42 +08:00
  • 07f13fd883 fix: remove unnecessary synchronized to improve concurrency (#8840) Zhanhui Li 2024-10-21 09:25:55 +08:00
  • 1e0b08f56a fix: make ConsumeQueueStore bottom most compression type configurable (#8841) Zhanhui Li 2024-10-18 16:50:13 +08:00
  • 49e23e1e0b fix: atomic flush incorrect use and clean up code (#8830) Zhanhui Li 2024-10-18 14:30:38 +08:00
  • 01f9848b74 fix variables match annotation (@RocketMQResource) (#8821) mawen12 2024-10-18 09:18:41 +08:00
  • 031687dbd7 [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
  • 4f5f705f16 [ISSUE #8780] Implement asynchronous storage of ack/ck messages in pop consume to enhance performance (#8727) lmq rongtong 2024-10-16 13:39:27 +08:00
  • a7dc023589 [ISSUE #8824] Fix IllegalStateException caused by logical errors (#8825) yx9o 2024-10-16 11:00:51 +08:00
  • 2fa7513a2b [ISSUE #8764] Implement consume lag estimation in cq rocksdb store (#8800) LetLetMe 2024-10-15 14:14:31 +08:00
  • 2355a5f784 [ISSUE #8816] Fix log typo. (#8817) luozongle01 2024-10-14 09:13:17 +08:00
  • 0c4064dc24 [ISSUE #8810] Fix independent execution of e2e and benchmark deployments (#8812) 小陈 2024-10-11 16:43:07 +08:00
  • 11f0002a3c [ISSUE #8806] fix autoBatch bug when connecting multiple RocketMQ clusters. (#8807) luozongle01 2024-10-11 15:29:18 +08:00
  • e75554d5a8 [ISSUE #8804] clean offset when remove group offset Lei Zhiyuan 2024-10-10 09:53:06 +08:00
  • c826373598 [ISSUE #8798] Fix typo (#8799) luozongle01 2024-10-10 09:52:45 +08:00
  • 6c90aace36 [ISSUE #8802] Update controller design.md (#8803) luozongle01 2024-10-10 09:48:30 +08:00
  • 95b1c51f86 Add Utils for put header to Metadata to avoid duplicate data. (#8792) dingshuangxi888 2024-10-09 10:37:19 +08:00
  • a948f67b4d [ISSUE #8796] Add more test coverage for PopLongPollingService (#8797) yx9o 2024-10-09 09:58:52 +08:00
  • 483a48a130 PrintMessageSubCommand support lmq (#8785) rongtong 2024-10-09 09:58:05 +08:00
  • 782da708d5 [ISSUE #8786] Fix doc typo (#8787) luozongle01 2024-10-08 17:42:23 +08:00
  • c5ac8a47ea [ISSUE #8782] Fix log typo (#8783) luozongle01 2024-10-05 10:09:07 +08:00
  • 6eb5a10191 Bump commons-io:commons-io from 2.7 to 2.14.0 (#8781) dependabot[bot] 2024-10-05 10:08:54 +08:00