Commit Graph

  • 8a36471a19 [ISSUE #7543] Add enableRetryTopicV2 brokerConfig (#7734) Zhouxiang Zhan 2024-01-11 11:11:53 +08:00
  • 3f99b1e96b [ISSUE #7707] Refector Context with link node implementation (#7708) Zhouxiang Zhan 2024-01-09 10:51:26 +08:00
  • 6fce427e10 [ISSUE ##7719] Add more property check for dealy message when auto-batch chack (#7720) zzl 2024-01-04 17:38:03 +08:00
  • 806454bc5e [ISSUE #7710] Handle blank string for UtilAll#split to fix the bugs of ACL Qinglong-Lee 2024-01-02 19:07:45 +08:00
  • 9e4fd0e68a [ISSUE #7697] Fix can't open controller metricsExporter. (#7705) baijun44 2023-12-28 15:39:10 +08:00
  • 2c5bc1422b Fix ascii validate for ppv2 tls. (#7703) dingshuangxi888 2023-12-27 19:09:52 +08:00
  • 59e8f9b66e [ISSUE #7644] Optimize client rebalance Zhouxiang Zhan 2023-12-27 10:42:50 +08:00
  • 620e6a2544 [ISSUE #7642] Add return value for sendHeartbeat related method Zhouxiang Zhan 2023-12-27 10:42:22 +08:00
  • 4bb4d78f1d [ISSUE #7686] The bornTime is not set when using the popMessage API in cluster mode. (#7687) dingshuangxi888 2023-12-22 15:55:00 +08:00
  • 2c898c9b31 [ISSUE #7689] In Controller mode, messages may lost due to sharing the same cq offset (#7690) Ji Juntao 2023-12-21 14:41:51 +08:00
  • a79b52991a Bump guava version from 31.1-jre to 32.0.1-jre (#7688) rongtong 2023-12-20 20:52:11 +08:00
  • f0a3e933b9 [ISSUE #7684] Fix iterator.remove() bug (#7682) EvanMi 2023-12-20 14:34:53 +08:00
  • fbfc066695 Bump guava version from 31.1-jre to 32.0.1-jre (#7681) rongtong 2023-12-20 11:49:20 +08:00
  • c10121697a [ISSUE #7676] use clientDecode for consuming message directly (#7677) cserwen 2023-12-20 10:12:15 +08:00
  • 403ad6f66c [ISSUE #7679] Optimize the serialization of RemotingCommand processTimer property (#7683) mxsm 2023-12-20 08:45:08 +08:00
  • 9dec4cf5fe [ISSUE #7669] map variable delayLevelTable changed to ConcurrentSkipListMap from ConcurrentHashMap (#7675) YASH PATEL 2023-12-19 17:17:13 +05:30
  • 80c0330f75 ConfirmOffset directly takes the max offset when allAckInSyncStateSet is false (#7657) rongtong 2023-12-18 10:10:28 +08:00
  • 086a726c5d [ISSUE #7659]Trim property Dongyuan Pan 2023-12-18 08:29:54 +08:00
  • 7e1786732c [ISSUE #7626] Topic perm was mistakenly changed to 4 in dledger mode (#7661) littleboy 2023-12-15 17:49:47 +08:00
  • 23ee0eaaef [ISSUE #7646] Optimize pull onException logging (#7647) Zhouxiang Zhan 2023-12-15 16:49:44 +08:00
  • 71a7a659be [ISSUE #7543] only call a single type of retry topic in pop (#7665) Zhouxiang Zhan 2023-12-15 16:09:11 +08:00
  • 8e585d8767 [ISSUE #7543] Use "+" as the new separator for retry topic (#7655) Zhouxiang Zhan 2023-12-15 16:08:43 +08:00
  • a53a9f0249 Remove getBrokerClusterAclConfig from admin and server (#7653) rongtong 2023-12-15 10:19:32 +08:00
  • 20b838838d Add validation in broker/namesrv configure updating command (#7649) rongtong 2023-12-15 10:08:48 +08:00
  • c14b0e99da [4.9.x] Bump snakeyaml version from 1.32 to 2.0 (#7663) dinglei 2023-12-15 09:58:50 +08:00
  • 50a92a2474 [ISSUE #7585] Always return duplicate buffer when filter message and fix log format (#7654) lizhimins 2023-12-13 19:50:19 +08:00
  • a376fbcdb8 [ISSUE #7634] Introduce controllableOffset to prevent unnecessary suspension when OFFSET_ILLEGAL (#7635) Zhouxiang Zhan 2023-12-12 16:52:12 +08:00
  • f7a6d0b73a Bump grpc from 1.50.0 to 1.53.0 (#7633) rongtong 2023-12-12 16:22:21 +08:00
  • 9a5690b91a Bump snakeyaml from 1.32 to 2.0 (#7632) rongtong 2023-12-12 16:21:22 +08:00
  • 1e69e3904f Fix flaky test testSemiSyncReplicaWhenAdaptiveDegradation (#7631) rongtong 2023-12-12 14:17:24 +08:00
  • d626d6087d Bump com.squareup.okio:okio-jvm from 3.0.0 to 3.4.0 (#7638) dependabot[bot] 2023-12-12 14:14:20 +08:00
  • bcc9db5cba [ISSUE #7614] Fix flaky test RocksDBMessageStoreTest (#7625) Zhanhui Li 2023-12-11 17:37:01 +08:00
  • faae64715d [ISSUE #7601] Fix slave acting master bug (#7603) gaoyf 2023-12-07 11:25:22 +08:00
  • c2c29c2435 [ISSUE #7545] Fix set mapped file to null cause file can not destroy (#7612) lizhimins 2023-12-04 16:13:07 +08:00
  • aec1055830 [ISSUE #7585] Support message filtering in rocketmq tiered storage (#7594) lizhimins 2023-12-04 16:12:42 +08:00
  • 65faea22fd [ISSUE #7534] Use high performance concurrent set to replace copyonwriteset (#7583) keranbingaa 2023-12-01 10:05:16 +08:00
  • 56e886bf70 [ISSUE #7592] testCleanBuffer unit test modifies, changed non-direct … (#7593) YASH PATEL 2023-11-29 10:02:38 +05:30
  • a194e1eb9a Add set method for config black list. (#7586) dinglei 2023-11-28 20:18:53 +08:00
  • 430ee0a755 Add validation in broker container configure updating command. (#7587) rongtong 2023-11-28 16:11:14 +08:00
  • 9cfe724e6a Add validation in broker/namesrv configure updating command (#7584) dinglei 2023-11-28 10:04:17 +08:00
  • 3a6bf967b5 [ISSUE #7579] Fix globalWhiteRemoteAddressStrategy cocurrent bug Lei Zhiyuan 2023-11-24 10:55:11 +08:00
  • e955e4399c [ISSUE #7577] SlaveActingMaster Timer Message retry without escape logic (#7578) AYue 2023-11-24 10:47:08 +08:00
  • 5b43387be3 [ISSUE #7543] Retry topic v2 in pop (#7544) Zhouxiang Zhan 2023-11-23 14:53:48 +08:00
  • a7d493b2fb transactionProducer get the topic route before sending the message (#7569) panzhi 2023-11-21 20:55:35 +08:00
  • ca721b0145 [ISSUE #7462] Remove deprecated LocalTransactionExecuter (#7463) zhanghong 2023-11-21 14:03:24 +08:00
  • 63130f51e8 [ISSUE #7545] [RIP-65] Support efficient random index for massive messages (#7546) lizhimins 2023-11-21 13:57:44 +08:00
  • 8e7e2b5f50 [ISSUE #7574] Fix RunningFlags conflict guyinyou 2023-11-20 19:32:57 +08:00
  • 01a2aef96b [ISSUE #7570] Add default value for lastPopTimestamp (#7571) cnScarb 2023-11-17 15:58:14 +08:00
  • 651a5ca992 [ISSUE #7562] BugFix for estimating message accumulation correctly (#7563) Jixiang Jin 2023-11-16 10:16:16 +08:00
  • 4791d9a1f1 [ISSUE #5923] Revert "Fix tiered store README.md error about Configuration (#7436)" (#7557) lizhimins 2023-11-14 17:59:47 +08:00
  • 1be5ebc736 [ISSUE #7551] Reuse helper methods from Netty to free direct byte buffer (#7550) Zhanhui Li 2023-11-13 09:45:37 +08:00
  • 15d32db03b [ISSUE #7547] Let consumer be aware of message queue assignment change (#7548) Zhanhui Li 2023-11-13 09:44:25 +08:00
  • 27759f3556 Fix unstable UtilAllTest#testCalculateFileSizeInPath on Windows (#7419) Allon Murienik 2023-11-09 06:33:34 +02:00
  • 70dc93abbc Fix tiered store README.md error about Configuration (#7436) yangguodong 2023-11-08 21:14:54 -06:00
  • ead3d90501 [ISSUE #7511] Lock granularity issue causing LMQ message loss (#7525) Dongyuan Pan 2023-11-08 10:40:52 +08:00
  • 00965d8c11 [ISSUE #7531] Clear POP_CK when sending messages (#7532) lk 2023-11-06 09:46:39 +08:00
  • 46962c262c [ISSUE #7523] Message will flush timeout when transientStorePoolEnable=true and flushDiskType=SYNC_FLUSH (#7524) fujian-zfj 2023-11-02 13:47:16 +08:00
  • 26fa050148 [ISSUE #7501] The broker supports idempotence in creating topics (#7502) fuyou001 2023-10-27 16:28:17 +08:00
  • 48ef5ced46 [ISSUE #7505] Do not validate the length when deleting a topic rongtong 2023-10-26 14:43:24 +08:00
  • 91349f30b9 [ISSUE #7437] Add the CRC check of commitlog (#7468) guyinyou 2023-10-25 14:54:00 +08:00
  • f90c55341c [ISSUE #7497] Extract the frequency of calling updateNamesrvAddr into a configuration (#7498) lk 2023-10-24 16:13:36 +08:00
  • 38d267672a Remove getBrokerClusterAclConfig from admin and server (#7486) rongtong 2023-10-24 15:15:08 +08:00
  • 2043dd5034 [ISSUE #7493] Introduce a new event NettyEventType.ACTIVE (#7494) Zhouxiang Zhan 2023-10-24 10:29:43 +08:00
  • 8f020b397a [ISSUE #7489] Code comment enhancement in example (#7490) Ao Qiao 2023-10-23 16:34:10 +08:00
  • 3968c186a5 [ISSUE #7231] Fix: proxy client language error (#7200) weihubeats 2023-10-20 14:49:00 +08:00
  • dbc633d92b Check the input yaml and the path in ACL (#7475) Ji Juntao 2023-10-19 14:12:33 +08:00
  • f0f15b5e21 [ISSUE #7454] Utilizing cache to avoid duplicate parsing (#7455) guyinyou 2023-10-19 10:14:29 +08:00
  • 82b2f8eefa AddBroker removes parsing configuration from body (#7472) rongtong 2023-10-18 13:51:47 +08:00
  • d73b601382 [ISSUE #7330] Fix channel connect issue for goaway (#7467) Zhouxiang Zhan 2023-10-16 19:06:40 +08:00
  • 3a035d75d7 [ISSUE #7464] Polish the pop logger format (#7465) Ao Qiao 2023-10-16 15:56:48 +08:00
  • 0f01df460f [ISSUE 7265] Doc: Adding how to debug in Idea document (#7266) Ao Qiao 2023-10-16 11:37:25 +08:00
  • f565654351 [ISSUE #7064] [RIP-66-2] Support KV(RocksDB) Storage for ConsumeQueue (#7120) fujian-zfj 2023-10-14 11:04:04 +08:00
  • 2113fa371b [ISSUE #7453] Fix the problem in constructing the GetMessageResult (#7456) guyinyou 2023-10-13 13:47:09 +08:00
  • dc62d7f2e1 [ISSUE #7451] Override toString for TopicConfigAndQueueMapping LetLetMe 2023-10-13 13:45:48 +08:00
  • 28427d4012 [ISSUE #7425] Add RoccketmqControllerConsole log to fix bug (#7458) Lei Sun 2023-10-13 13:42:27 +08:00
  • 5d492c3382 [ISSUE #7444] Fix testCalculateFileSizeInPath test can not rerun in same environment (#7445) rongtong 2023-10-13 11:23:30 +08:00
  • 7e4879a3bc [ISSUE #7441] Fix log "Init the confirmOffset" keep printing error in controller mode (#7442) fujian-zfj 2023-10-11 14:45:07 +08:00
  • dc3f22ffe9 add getter for class Message ,fix json serialize bug (#7439) LetLetMe 2023-10-10 17:39:23 +08:00
  • 4acb43ecee [ISSUE #7330] Add goaway and reconnection mechanism (#7331) Zhouxiang Zhan 2023-10-10 13:54:01 +08:00
  • 38d3d5d95d [ISSUE #7433]Update the version in the README.md document to 5.1.4 (#7434) mxsm 2023-10-10 09:37:04 +08:00
  • b18e564add [ISSUE #7431] Fix flaky test of DLedgerControllerTest#testBrokerLifecycleListener (#7432) rongtong 2023-10-09 21:43:01 +08:00
  • 0027a1486d [ISSUE #7412] Fix pop revive message error when reput checkpoint redlsz 2023-10-09 16:52:10 +08:00
  • 3808387e13 [ISSUE #7429] clean channel map when CLIENT_UNREGISTER in proxy lk 2023-10-09 16:07:56 +08:00
  • b9ffe0f957 [ISSUE #7296] Add ChannelEventListener for MQClientAPIImpl (#7324) Zhouxiang Zhan 2023-10-08 16:33:44 +08:00
  • 84156084a4 [ISSUE #7321] Refector NettyRemotingAbstract with unify future implementation (#7322) Zhouxiang Zhan 2023-10-08 11:13:25 +08:00
  • c36bb78e85 [ISSUE 7313] Enhancement Optimization Method name (#7420) shriVATSA54 2023-10-07 12:22:39 +05:30
  • 4f1b42a7c5 [ISSUE #7410] Handle the Exception when the Proxy requests the client ShuangxiDing 2023-09-28 16:52:02 +08:00
  • 0a6ae4605f [ISSUE #7396] Fix wrong word in BrokerController#doResterBrokerAll (#7397) tiger lee 2023-09-27 14:43:15 +08:00
  • 959a98120c [ISSUE #7400] Fix getBrokerEpochSubCommand NPE 石臻臻(Steven shi) 2023-09-27 01:59:58 +08:00
  • c3b86cd1e3 [ISSUE #7398] Fix ExportConfigsCommand NPE (#7399) 石臻臻(Steven shi) 2023-09-26 16:07:13 +08:00
  • 3fd43353fd [ISSUE #7393] Add timeout configuration for grpc server (#7394) Zhouxiang Zhan 2023-09-26 13:53:51 +08:00
  • d7e5c4d1a4 [ISSUE #7389] Fix the problem that getLastMappedFile function affects performance guyinyou 2023-09-25 13:37:36 +08:00
  • 88a9d939ce [ISSUE #7381] Fix the problem of inaccurate timer message metric (#7382) Ji Juntao 2023-09-23 17:38:27 +08:00
  • 73b3fde837 [maven-release-plugin] prepare for next development iteration (#7379) lk 2023-09-22 10:08:59 +08:00
  • 1a681bdf9b [maven-release-plugin] prepare release rocketmq-all-5.1.4 (#7377) rocketmq-all-5.1.4 release-5.1.4 lk 2023-09-21 19:58:29 +08:00
  • b8610d87bb Replace loggingMetricExporter with OtlpJsonLoggingMetricExporter. (#7373) Jixiang Jin 2023-09-21 16:21:44 +08:00
  • 42fcd278ca [ISSUE #7374] Prepare to release Apache RocketMQ 5.1.4 (#7375) lk 2023-09-20 15:41:23 +08:00
  • f05a8da760 Print admin queue watermark in log (#7372) rongtong 2023-09-20 15:06:21 +08:00
  • 831fcc76cd [ISSUE #7363] Fix get message from tiered storage return incorrect next pull offset (#7365) lizhimins 2023-09-19 10:04:04 +08:00
  • 4a8e0d5b85 [ISSUE #7351] Allow mqadmin to operate slave nodes guyinyou 2023-09-13 16:08:03 +08:00