RocketMQ Rust Release 🔖v0.3.0

New Feature and improve performance

• ✨The client sdk is provided (rocketmq-client)
• ⚡️Use Cheetah String to improve performance
• 🚀Optimize an existing crate

What's Changed

• [ISSUE #427]⬆️Upgrade the version to 0.3.0 for the next version's feature development📌 by @mxsm in #428
• [ISSUE #429]⬆️Upgrade the version to 0.3.0 for the next version's feature development📌 by @mxsm in #430
• [ISSUE #431]🔨Add rocketmq rust crate package and publish scripts🔨 by @mxsm in #432
• [ISSUE #433]👷Improving Methods of TopicQueueMappingManager Struct by @mxsm in #434
• [ISSUE #435]⚡️Improving broker receive a single message🎨 by @mxsm in #436
• [ISSUE #437]🔥Remove useless code by @shadowsoy in #438
• [ISSUE #439]⚡️Implementing Functionality Methods of HookUtils.java🎨 by @mxsm in #440
• [ISSUE #441]🔥Improving PutMessageHook logic🚀 by @mxsm in #442
• [ISSUE #443✅]Add test case for BloomFilterData💚 by @flydream-ylgw in #444
• [ISSUE #445]✅Add test case for ConsumeFromWhere by @yulanggongwu in #446
• [ISSUE #447]✨ Add stats struct by @SpaceOneT in #448
• [ISSUE #449]🎨Optimize SendMessageProcessor#process_request method by @yulanggongwu in #450
• [ISSUE #451] ✨Add MomentStatsItem struct 🚀 by @flydream-ylgw in #452
• [ISSUE #453] 🚧Add StatsSnapshot struct by @flydream-ylgw in #454
• [ISSUE #455] ✨Add CallSnapshot struct by @antcarryele in #456
• [ISSUE #457]🚀Enhance the functionality of BrokerStatsManager by @mxsm in #458
• [ISSUE #459]🚀Enhance the functionality of BrokerStatsManager -2🎨 by @mxsm in #460
• [ISSUE #461]🎉Add StatisticsItem struct 🎉 by @flydream-ylgw in #462
• [ISSUE #463] ✨Add StatisticsItemFormatter struct by @flydream-ylgw in #464
• [ISSUE #465]🔖Enhance the functionality of BrokerStatsManager -3 by @mxsm in #466
• [ISSUE #467]🔥Optimize broker start and init by @mxsm in #468
• [ISSUE #469]🚀Develop BrokerRuntime initializeBrokerScheduledTasks🚀 by @mxsm in #470
• [ISSUE #471]🔥Optimize Broker start🚑️ by @mxsm in #472
• [ISSUE #473]🎨Reformat the code🎨 by @mxsm in #474
• [ISSUE #475]🔧Add Cargo.lock💡 by @mxsm in #476
• [ISSUE #477]✅Add test case for BrokerAddrInfo and BrokerStatusChangeInfo 🚀 by @ButterflyEffect1991 in #478
• [ISSUE #479]🔥Optimize broker register and client scan_available_name_srv🎨 by @mxsm in #480
• Bump bytes from 1.5.0 to 1.6.0 by @dependabot in #482
• Bump proc-macro2 from 1.0.76 to 1.0.85 by @dependabot in #491
• Bump anyhow from 1.0.79 to 1.0.86 by @dependabot in #490
• Bump clap from 4.4.17 to 4.5.7 by @dependabot in #489
• Bump quote from 1.0.35 to 1.0.36 by @dependabot in #487
• Bump tokio-util from 0.7.10 to 0.7.11 by @dependabot in #486
• Bump thread_local from 1.1.7 to 1.1.8 by @dependabot in #484
• Bump parking_lot from 0.12.2 to 0.12.3 by @dependabot in #488
• Bump tokio-stream from 0.1.14 to 0.1.15 by @dependabot in #485
• Bump serde_json from 1.0.111 to 1.0.117 by @dependabot in #483
• [ISSUE #481] 🍻Optimize error handle by @TeslaRustor in #492
• [ISSUE #493] 🍻Optimize broker out api registers broker by @mxsm in #494
• [ISSUE #495]🚀Optimize RemotingClient trait by @TeslaRustor in #496
• [ISSUE #497]🐛Ensure compatibility with the deserialization of lower versions of HeartbeatData by @flydream-ylgw in #498
• [ISSUE #499]🎨Add default value for struct by @mxsm in #500
• [ISSUE #501] ✅Add test case for HeartbeatData by @flydream-ylgw in #502
• Bump syn from 2.0.48 to 2.0.66 by @dependabot in #507
• Bump crc32fast from 1.3.2 to 1.4.2 by @dependabot in #506
• Bump tokio from 1.35.1 to 1.38.0 by @dependabot in #505
• Bump thiserror from 1.0.56 to 1.0.61 by @dependabot in #504
• Bump serde from 1.0.195 to 1.0.203 by @dependabot in #503
• [ISSUE #508] ✨Add fast broker server by @shadowsoy in #509
• [ISSUE #510]✨Broker supports batch message storage🚀 by @mxsm in #511
• [ISSUE #512]🔥Implementing Functionality do append batch messages🚀 by @shadowsoy in #513
• [ISSUE #514]🚀Add CodeRabbit 🔨 by @mxsm in #515
• [ISSUE ##516]✅Add test case for StoreType 🚧 by @shadowsoy in #517
• [ISSUE #518]🚀Optimzie get data from Bytes by @mxsm in #519
• [ISSUE #520] 🐛Fix count_inner_msg_num method of message decoder mode by @dream-cloud-fly in #521
• Bump codecov/codecov-action from 4.4.1 to 4.5.0 by @dependabot in #522
• [ISSUE ##523] 🔨Add auto request review by @mxsm in #524
• [ISSUE ##525]🔨 Add auto comment on PR by @mxsm in #526
• [ISSUE #529]🔨Optimize Auto Comment on PR by @mxsm in #530
• [ISSUE ##527]🔨Optimize auto request review by @mxsm in #528
• [ISSUE ##531] 🎨Optimize thread local code by @shadowsoy in #532
• [ISSUE # #533] 🔨Optimize auto request review config file by @shadowsoy in #534
• [ISSUE #537]🔨Optimize auto request review config file by @mxsm in #538
• [ISSUE #535]✅Add test case for CleanupPolicy by @shadowsoy in #536
• [ISSUE #539]🔨Optimize Auto Comment on PR by @mxsm in #540
• [ISSUE #542]🔨Add auto add label for pr approval by @mxsm in #543
• [ISSUE #541]🔨Add Auto-Merge by @mxsm in #544
• [ISSUE #545]🔧Update label-on-approval.yml by @mxsm in #546
• [ISSUE #547]🔧Update automerge.yml by @mxsm in #548
• [ISSUE #549]🔧Update automerge.yml by @mxsm in #550
• [ISSUE #553]🔧Update workflows config file by @mxsm in #554
• [ISSUE #551]🔥Remove useless code by @dream-cloud-fly in #552
• [ISSUE #555]🔨Update label-on-approval.yml by @mxsm in #556
• [ISSUE #560]🔧Update workflows config file by @mxsm in #561
• [ISSUE #565]🔨Update label-on-approval.yml by @flydream-ylgw in #566
• [ISSUE #563]🔧Update auto-comment-pr.yml by @ButterflyEffect1991 in #564
• [ISSUE #568]🔨Update label-on-approval.ym by @mxsm in #569
• Update label-on-approval.yml by @mxsm in #571
• Update label-on-approval.yml by @mxsm in #573
• Update label-on-approval.yml by @mxsm in #576
• Update label-on-approval.yml by @mxsm in #577
• Update label-on-approval.yml by @mxsm in #581
• Update config file by @mxsm in #582
• Update config file by @mxsm in #584
• update config file by @mxsm in #587
• update config file by @mxsm in #588
• update config file by @mxsm in #589
• Update automerge.yml by @mxsm in #591
• Update automerge.yml by @mxsm in #594
• Update automerge.yml by @mxsm in #596
• Update automerge.yml by @mxsm in #597
• Update automerge.yml by @mxsm in #598
• Update automerge.yml by @mxsm in #599
• Update auto-comment-pr.yml by @yulanggongwu in #595
• Update automerge.yml by @mxsm in #600
• Update automerge.yml by @mxsm in #601
• [ISSUE #592]Add doc for StatisticsItemScheduledPrinter struct by @flydream-ylgw in #593
• Update automerge.yml by @mxsm in #602
• Update automerge.yml by @mxsm in #604
• Update auto-comment-pr.yml by @flydream-ylgw in #603
• Update auto-comment-pr.yml by @mxsm in #605
• Update auto-comment-pr.yml by @flydream-ylgw in #606
• Update auto-comment-pr.yml by @mxsm in #607
• Update auto_request_review.yml by @flydream-ylgw in #608
• Create label-on-approval.yml by @mxsm in #609
• Update automerge.yml by @mxsm in #611
• Update dependabot.yml by @flydream-ylgw in #610
• Update label-on-approval.yml by @mxsm in #613
• Update label-on-approval.yml by @mxsm in #614
• Update label-on-approval.yml by @mxsm in #615
• Update label-on-approval.yml by @mxsm in #616
• Create work_flow_watch.yml by @mxsm in #617
• Update label-on-approval.yml by @mxsm in #618
• Update label-on-approval.yml by @mxsm in #619
• Update work_flow_watch.yml by @mxsm in #620
• Mxsm patch 1 by @mxsm in #621
• Update auto-comment-pr.yml by @mxsm in #622
• Delete .github/workflows/work_flow_watch.yml by @mxsm in #623
• Update Cargo.toml by @flydream-ylgw in #612
• Update automerge.yml by @mxsm in #624
• Update auto-comment-pr.yml by @mxsm in #625
• Delete .github/workflows/label-on-approval.yml by @flydream-ylgw in #626
• [ISSUE #627]🔧Optimize auto actions config by @mxsm in #629
• [ISSUE #630]✅Add test case for TopicConfigAndMappingSerializeWrapper by @mxsm in #631
• [ISSUE #574] ✅Add test case for MessageQueue by @ButterflyEffect1991 in #632
• [ISSUE #633]🔧 Add test template by @flydream-ylgw in #634
• [ISSUE #635]🔧Update actions auto config by @mxsm in #636
• [ISSUE #637]✅ Add test case for TopicList by @yulanggongwu in #638
• [ISSUE #639]🔧Update auto actions token with PAT by @mxsm in #640
• [ISSUE #641]🎨Optimize ProducerManager#unregister_producer by @flydream-ylgw in #642
• [ISSUE #643]🐛Fix topic_config_and_mapping_serialize_wrapper_default t… by @mxsm in #644
• [ISSUE #645]🐛Fix test case topic_config_and_mapping_serialize_wrapper_getters error by @mxsm in #646
• [ISSUE #647]🚧Enhance the functionality of BrokerStatsManager-4 by @mxsm in #648
• [ISSUE #649]✅Fix DataVersion test case for data_version_next_version error by @shadowsoy in #650
• [ISSUE ##651]🚀Enhance the functionality of BrokerStatsManager-5 by @TeslaRustor in #652
• [ISSUE #653]🐛Fix Broker can not start by @mxsm in #654
• [ISSUE ##656] 🎨Add ConsumeMessageContext struct and ConsumeMessageHook trait by @shadowsoy in #657
• [ISSUE #660]🔧Update rustfmt.toml by @TeslaRustor in #661
• [ISSUE #658]🚀Support pull message consume by @mxsm in #659
• Bump dashmap from 5.5.3 to 6.0.0 by @dependabot in #663
• [ISSUE #662]🚀Support pull message consume-2 by @mxsm in #664
• [ISSUE #665]🚀Implemention ConsumerGroupInfo struct by @mxsm in #666
• [ISSUE #667]🍻Optimize socket connection by @mxsm in #668
• [ISSUE #669]🚀Support pull message consume-3 by @mxsm in #670
• Bump lazy_static from 1.4.0 to 1.5.0 by @dependabot in #673
• Bump proc-macro2 from 1.0.85 to 1.0.86 by @dependabot in #672
• Bump syn from 2.0.66 to 2.0.67 by @dependabot in #674
• [ISSUE #671]🚀Support pull message consume-4 by @mxsm in #675
• [ISSUE #676]♻️Refactor RemotingCommand struct🚀 by @mxsm in #677
• [ISSUE #678]🚀Support rocketmq serialize type by @mxsm in #679
• [ISSUE #680]🐛Fix Broker can not start by @mxsm in #681
• [ISSUE #682]🚀Optimize ResponseCode by @mxsm in #683
• [ISSUE #684]🎨Optimize RocketmqDefaultClient struct by @TeslaRustor in #685
• [ISSUE #686]🚀Support GET_CONSUMER_LIST_BY_GROUP(38) request code⚡️ by @mxsm in #687
• Bump dashmap from 6.0.0 to 6.0.1 by @dependabot in #690
• Bump syn from 2.0.67 to 2.0.68 by @dependabot in #689
• Bump uuid from 1.8.0 to 1.9.1 by @dependabot in #688
• [ISSUE #323]🚀Support heart beat (requst code 34)-consumer by @mxsm in #691
• [ISSUE #692]🚀Support QueryConsumerOffset(14) request🚀 by @mxsm in #693
• Bump serde_json from 1.0.117 to 1.0.118 by @dependabot in #694
• Bump mio from 0.8.10 to 0.8.11 by @dependabot in #695
• [ISSUE #696]🚀Support pull message consume-5 by @TeslaRustor in #697
• [ISSUE #698]🚀Support UpdateConsumerOffset(15) request⚡️ by @mxsm in #700
• [ISSUE #699]🚀Support pull message result handle by @TeslaRustor in #701
• [ISSUE #704]🚀Add SerdeJsonUtils struct tool 🚀 by @mxsm in #705
• [ISSUE #702]🚀Support pull message result handle-2🚀 by @mxsm in #706
• [ISSUE #703]🚀Implement RpcClientUtils#encode_body method🚀 by @mxsm in #707
• [ISSUE #708]🚀Optimize TopicConfigManager🎨 by @mxsm in #709
• [ISSUE #711]🔨Add emoji for issue template by @flydream-ylgw in #712
• Bump log from 0.4.21 to 0.4.22 by @dependabot in #714
• Bump clap from 4.5.7 to 4.5.8 by @dependabot in #713
• [ISSUE #715]✅Add test case for ClientChannelInfo by @alax-cat in #716
• [ISSUE #717]⚡️Optimize ConsumerOffsetManager by @mxsm in #718
• [ISSUE #719]⚡️Add SyncUnsafeCell and Mutex bench by @mxsm in #720
• [ISSUE #710]🚀Support pull message result handle-3🎨 by @mxsm in #721
• [ISSUE ##724]🚀Add MessageArrivingListener by @mxsm in #725
• Bump serde_json from 1.0.118 to 1.0.120 by @dependabot in #726
• [ISSUE #723]⚡️Optimize ConnectionHandlerContext⚡️ by @mxsm in #727
• [ISSUE #722]🚀Support pull message result handle-4 by @mxsm in #728
• [ISSUE #729]⚡️Optimize pull message by @mxsm in #730
• [ISSUE #731]🚀Optimize SubscriptionGroupConfig default method 🔥 by @mxsm in #732
• [ISSUE #733]🚀Optimize pull message🔥 by @mxsm in #734
• [ISSUE #735] 🔥Optimize pull message logic by @mxsm in #736
• [ISSUE #737]🔥Optimize PullMessageProcessor init⚡️ by @mxsm in #738
• [ISSUE #739]🔥Improve the pull message consumption pattern🚀 by @mxsm in #740
• [ISSUE #741]🚀Implement ExpressionMessageFilter tags🔥 by @mxsm in #742
• Bump serde from 1.0.203 to 1.0.204 by @dependabot in #745
• Bump zstd from 0.13.1 to 0.13.2 by @dependabot in #743
• Bump syn from 2.0.68 to 2.0.70 by @dependabot in #744
• [ISSUE #746]🐛Java Client can not consumer message by @mxsm in #747
• [ISSUE ##748]🔥Implement message arrival notification for consumers🎨 by @mxsm in #749
• [ISSUE #752]🍻init rocketmq-example crate🤡 by @mxsm in #753
• [ISSUE #751]🤡init rocketmq-client crate🍻 by @mxsm in #754
• Bump sysinfo from 0.30.12 to 0.30.13 by @dependabot in #755
• Bump clap from 4.5.8 to 4.5.9 by @dependabot in #757
• Bump uuid from 1.9.1 to 1.10.0 by @dependabot in #756
• [ISSUE #750]✨Add client meta data struct by @mxsm in #758
• [ISSUE #759]🐛Fix Pull Message execute_request_when_wakeup by @shadowsoy in #760
• [ISSUE #761]🔥Optimize Pull message rewrite static topic🚀 by @mxsm in #762
• [ISSUE #763]🔥Topic manager support(Request code:17,18,21,215) 🚀 by @mxsm in #764
• [ISSUE #765]♻️Refactor ConsumeQueueStore🚀 by @mxsm in #766
• Bump syn from 2.0.70 to 2.0.71 by @dependabot in #770
• Bump thiserror from 1.0.61 to 1.0.62 by @dependabot in #769
• [ISSUE #768]♻️Replace SyncUnsafeCell with ArcCellWrapper🔥 by @mxsm in #771
• [ISSUE #767]🔥Refactor all error handling🚀 by @mxsm in #772
• [ISSUE #773]🔥Optimize Topic request handle⚡️ by @mxsm in #774
• [ISSUE #775]⚡️Optimize test_start_and_shutdown test case✅ by @ButterflyEffect1991 in #776
• [ISSUE #777]🔥Fix Broker can not started🐛 by @mxsm in #778
• [ISSUE #779]🎨Optimize CommandCustomHeader trait✨ by @mxsm in #780
• [ISSUE #782]🚀PullMessageResponseHeader implement FastCodesHeader🚀 by @mxsm in #783
• [ISSUE #784]🔥Support ROCKETMQ SerializeType🔥 by @mxsm in #785
• [ISSUE #786]🚀Optimize SendMessageRequestHeader and SendMessageRequestHeaderV2🔥 by @mxsm in #787
• [ISSUE #788]⚡️Optimize and refine the process of sending messages🚀 by @mxsm in #789
• [ISSUE #790]🚀Support Query message(request code :12,33)🔥 by @mxsm in #791
• Bump bytes from 1.6.0 to 1.6.1 by @dependabot in #792
• [ISSUE #793]🔥Implement SendMessageProcessor#handleRetryAndDLQ ✨ by @mxsm in #794
• [ISSUE #795]📝Add doc for trait🎨 by @mxsm in #796
• [ISSUE #797]🎨Extract NamespaceUtil from the protocol🔥 by @mxsm in #798
• Bump tokio from 1.38.0 to 1.38.1 by @dependabot in #799
• [ISSUE #800]✨Implement the TopicQueueLock🚀 by @mxsm in #801
• [ISSUE #802]🔥Optimze CommitLog#put_message method, add TopicQueueLock⚡️ by @mxsm in #803
• Bump thiserror from 1.0.62 to 1.0.63 by @dependabot in #804
• [ISSUE #805]🐛register borker error will effect broker running 🔥 by @mxsm in #806
• [ISSUE #56] broker registration log. by @847850277 in #807
• [ISSUE #808] register broker data version null by @847850277 in #809
• [ISSUE #811]🎨Refactor Client error handle🔥 by @mxsm in #812
• [ISSUE #813]🔥Refactor processor error handle🚀 by @mxsm in #814
• Issues #810 Optimize TopicConfigAndMappingSerializeWrapper by @847850277 in #815
• Bump mockall from 0.12.1 to 0.13.0 by @dependabot in #818
• Bump syn from 2.0.71 to 2.0.72 by @dependabot in #817
• [ISSUE #816]⚡️Improve message delivery🚀 by @mxsm in #819
• Bump clap from 4.5.9 to 4.5.10 by @dependabot in #822
• Bump tokio from 1.38.1 to 1.39.1 by @dependabot in #821
• Bump env_logger from 0.11.3 to 0.11.4 by @dependabot in #820
• [ISSUE #825]Optimize MessageStore#put_message method by @mxsm in #826
• [ISSUE #823] Support AdminBrokerProcessor get_broker_config by @847850277 in #824
• [ISSUE #827] Optimize put message thread local by @mxsm in #828
• Bump clap from 4.5.10 to 4.5.11 by @dependabot in #831
• Bump env_logger from 0.11.4 to 0.11.5 by @dependabot in #830
• [ISSUE #829]Optimize AppendMessageCallback#do_append method by @mxsm in #832
• [ISSUE #835]Optimize MappedFile#append_message_offset_length method by @mxsm in #838
• [ISSUE #837]Fix Broker can't push messages to the client in a timely manner for consumption by @mxsm in #839
• [ISSUE #834]Support AdminBrokerProcessor get_system_topic_list_from_broker by @847850277 in #836
• [ISSUE #840]Optimize code logic by @mxsm in #841
• [ISSUE #842]✨Add MQAdmin trait for sdk client🚀 by @mxsm in #843
• [ISSUE #844]✨Add MQProducer trait for sdk client🚀 by @mxsm in #845
• [ISSUE #846]✨Implement DefaultMQProducer#start-1🚀 by @mxsm in #848
• Bump serde_json from 1.0.120 to 1.0.121 by @dependabot in #852
• Bump tokio from 1.39.1 to 1.39.2 by @dependabot in #851
• [ISSUES #833] Support AdminBrokerProcessor get_topic_stats_info. by @847850277 in #849
• [ISSUES #850] Support AdminBrokerProcessor get_topic_config. by @847850277 in #853
• [ISSUE #847]🚀Implement DefaultMQProducer#start-2 by @mxsm in #855
• Bump sysinfo from 0.30.13 to 0.31.0 by @dependabot in #858
• Bump clap from 4.5.11 to 4.5.13 by @dependabot in #857
• Bump bytes from 1.6.1 to 1.7.0 by @dependabot in #856
• Bump sysinfo from 0.31.0 to 0.31.2 by @dependabot in #863
• Bump serde_json from 1.0.121 to 1.0.122 by @dependabot in #862
• Bump bytes from 1.7.0 to 1.7.1 by @dependabot in #861
• Bump tempfile from 3.10.1 to 3.11.0 by @dependabot in #865
• Bump regex from 1.10.5 to 1.10.6 by @dependabot in #864
• [ISSUES #854] Enhance serialization for map structures. by @847850277 in #859
• [ISSUE #866]Optimize Producer start by @mxsm in #867
• [ISSUE #868]Add a Producer example by @mxsm in #869
• [ISSUE #870] Implement DefaultMQProducerImpl#start by @mxsm in #871
• Bump reqwest from 0.11.27 to 0.12.5 by @dependabot in #875
• Bump flate2 from 1.0.30 to 1.0.31 by @dependabot in #874
• Bump tabled from 0.15.0 to 0.16.0 by @dependabot in #873
• Bump tempfile from 3.11.0 to 3.12.0 by @dependabot in #876
• [ISSUES #860] Support AdminBrokerProcessor get_broker_runtime_info part#1 by @847850277 in #877
• [ISSUE #872]Implement Produer send single message-1 by @mxsm in #880
• Bump clap from 4.5.13 to 4.5.14 by @dependabot in #881
• Bump serde from 1.0.204 to 1.0.205 by @dependabot in #882
• [ISSUE #879]Implement Produer send single message-2 by @mxsm in #884
• [ISSUE #883]Implement Produer send single message-3 by @mxsm in #885
• Bump syn from 2.0.72 to 2.0.74 by @dependabot in #890
• Bump serde from 1.0.205 to 1.0.207 by @dependabot in #888
• Bump serde_json from 1.0.122 to 1.0.124 by @dependabot in #889
• Bump clap from 4.5.14 to 4.5.15 by @dependabot in #887
• [ISSUES #878] Support AdminBrokerProcessor get_broker_runtime_info part#2 by @847850277 in #891
• [ISSUE #886]Optimize produer send single message by @mxsm in #893
• [ISSUES #892] Support AdminBrokerProcessor query_topics_by_consumer by @847850277 in #895
• [ISSUE #896]🔥Implement Produer send batch message🚀 by @mxsm in #897
• Bump clap from 4.5.15 to 4.5.16 by @dependabot in #900
• Bump serde from 1.0.207 to 1.0.208 by @dependabot in #899
• Bump serde_json from 1.0.124 to 1.0.125 by @dependabot in #898
• [ISSUES #894] Support AdminBrokerProcessor query_topic_consume_by_who by @847850277 in #903
• [ISSUE #902]✨Implement Produer send batch message other methods🔥 by @mxsm in #904
• [ISSUE #901]🔥Implement Produer send single message other methods🚀 by @mxsm in #905
• [ISSUE #906]Implement ProduceAccumulator-1 by @mxsm in #907
• [ISSUE #908]Implement mq producer other methods-1 by @mxsm in #911
• Bump tokio from 1.39.2 to 1.39.3 by @dependabot in #914
• Bump reqwest from 0.12.5 to 0.12.7 by @dependabot in #913
• Bump syn from 2.0.74 to 2.0.75 by @dependabot in #912
• [ISSUE #910]🚀Implement mq producer other methods-2🚀 by @mxsm in #915
• Bump flate2 from 1.0.31 to 1.0.32 by @dependabot in #917
• [ISSUE #918]📝Update README.md by @mxsm in #919
• Bump quote from 1.0.36 to 1.0.37 by @dependabot in #921
• Bump sysinfo from 0.31.2 to 0.31.3 by @dependabot in #923
• Bump serde_json from 1.0.125 to 1.0.127 by @dependabot in #922
• [ISSUES #909] Support AdminBrokerProcessor get_consumer_connection_list by @847850277 in #920
• [ISSUE #916]🚀Support producer send rpc message-1 by @mxsm in #925
• [ISSUE #927]📝Update README.md by @mxsm in #928
• [ISSUE #926]🔥Remoting connection implements read-write separation🚀 by @mxsm in #932
• Bump syn from 2.0.75 to 2.0.76 by @dependabot in #931
• Bump flate2 from 1.0.32 to 1.0.33 by @dependabot in #930
• Bump serde from 1.0.208 to 1.0.209 by @dependabot in #929
• [ISSUE #924]🔥Support producer send rpc message-2🚀 by @mxsm in #935
• Bump sysinfo from 0.31.3 to 0.31.4 by @dependabot in #933
• Bump local-ip-address from 0.6.1 to 0.6.2 by @dependabot in #936
• Bump tokio from 1.39.3 to 1.40.0 by @dependabot in #937
• [ISSUE #934]🔥Support producer send rpc message-3🚀 by @mxsm in #938
• [ISSUE #939]📈Add request callback proudcer example🔥 by @mxsm in #940
• [ISSUE #941]📝Update client README.md✨ by @mxsm in #942
• [ISSUE ##943]📝Update client README.md✏️ by @note-art in #944
• [ISSUE #945]Optimize request_callback_producer code style by @yulanggongwu in #946
• [ISSUE #947]🔥Implement broker rpc message ReplyMessageProcessor🚀 by @mxsm in #949
• Bump syn from 2.0.76 to 2.0.77 by @dependabot in #951
• [ISSUE #950]✨Support RequestCode GET_MAX_OFFSET/GET_MIN_OFFSET(30/31) in AdminBrokerProcessor🔥 by @mxsm in #952
• Bump serde_json from 1.0.127 to 1.0.128 by @dependabot in #955
• Bump clap from 4.5.16 to 4.5.17 by @dependabot in #957
• Bump tokio-util from 0.7.11 to 0.7.12 by @dependabot in #956
• [ISSUES #953] Support AdminBrokerProcessor get_consume_stats by @847850277 in #954
• Bump tokio-stream from 0.1.15 to 0.1.16 by @dependabot in #959
• Bump dashmap from 6.0.1 to 6.1.0 by @dependabot in #958
• [ISSUE #960]🚀Support client consumer message-1🔥 by @mxsm in #961
• Bump serde from 1.0.209 to 1.0.210 by @dependabot in #963
• Bump anyhow from 1.0.86 to 1.0.87 by @dependabot in #962
• [ISSUE #964]🚀Support client consumer message-2🚀 by @mxsm in #965
• [ISSUE #966]🚀Support client consumer message-3🚀 by @mxsm in #968
• [ISSUES #969] Support AdminBrokerProcessor get_all_consumer_offset by @847850277 in #970
• [ISSUE #967]🚀 Support client consumer message-4 🚀 by @mxsm in #971
• Bump once_cell from 1.19.0 to 1.20.0 by @dependabot in #976
• Bump anyhow from 1.0.87 to 1.0.88 by @dependabot in #975
• Bump memmap2 from 0.9.4 to 0.9.5 by @dependabot in #974
• Bump anyhow from 1.0.88 to 1.0.89 by @dependabot in #977
• Bump local-ip-address from 0.6.2 to 0.6.3 by @dependabot in #978
• Bump bytes from 1.7.1 to 1.7.2 by @dependabot in #979
• [ISSUE #972]🔥Supports client clusting consume🚀 by @mxsm in #980
• Bump clap from 4.5.17 to 4.5.18 by @dependabot in #982
• [ISSUE #983]🎨Optimize ConnectionHandler logic🔥 by @mxsm in #984
• [ISSUE #981]🔥Optimize client clusting consume⚡️ by @mxsm in #985
• [ISSUE #986]🚀Add Runtime for ConsumeMessageConcurrentlyService⚡️ by @mxsm in #987
• [ISSUE #988]🐛Fix rebalance_by_topic method bug in RebalanceImpl🔥 by @mxsm in #989
• Bump thiserror from 1.0.63 to 1.0.64 by @dependabot in #992
• Bump pascalgn/automerge-action from 0.16.3 to 0.16.4 by @dependabot in #991
• [ISSUE #990]🚀Support NOTIFY_CONSUMER_IDS_CHANGED(request code 40) for client by @mxsm in #993
• [ISSUE #994]⚡️Optimize RocketmqDefaultClient code by @mxsm in #995
• [ISSUE #996]📝Add doc for ConsumeFromWhere item by @mxsm in #997
• [ISSUE #998]📝Add doc for MQConsumerInner by @mxsm in #999
• [ISSUE #1002]🐛Fix clippy check error on ConfigManager by @mxsm in #1003
• [ISSUE #1000]✨Add RocketMQTokioRwLock and RocketMQTokioMutex for rocketmq crate🎨 by @mxsm in #1001
• [ISSUE #1006]🎨Fix code style by @mxsm in #1007
• [ISSUE #1004]🚀optimize and improve consume logic⚡️ by @mxsm in #1008
• Bump flate2 from 1.0.33 to 1.0.34 by @dependabot in #1005
• Bump syn from 2.0.77 to 2.0.79 by @dependabot in #1010
• [ISSUE #1014]📝Update README.md by @mxsm in #1015
• [ISSUE #1012]🚀Support client Broadcasting consume-local file store⚡️ by @mxsm in #1013
• [ISSUE #1016]📝Update README.md by @mxsm in #1017
• [ISSUE #1009]🚀Support client Broadcasting consume by @mxsm in #1018
• [ISSUE #1019]🐛Fix message queue changed sendHeartbeatToAllBrokerWithLockV2 faild by @mxsm in #1020
• [ISSUE #1022]⚡️Add Default trait for RocketMQTokioRwLock and RocketMQTokioMutex by @mxsm in #1023
• [ISSUE #1021]🚀Support mq client instance clean offline broker🎉 by @mxsm in #1024
• Bump tempfile from 3.12.0 to 3.13.0 by @dependabot in #1027
• Bump regex from 1.10.6 to 1.11.0 by @dependabot in #1028
• Bump reqwest from 0.12.7 to 0.12.8 by @dependabot in #1026
• Bump once_cell from 1.20.0 to 1.20.1 by @dependabot in #1025
• [ISSUE #1030]🚀Add order message produce example by @mxsm in #1031
• Bump codecov/codecov-action from 4.5.0 to 4.6.0 by @dependabot in #1033
• Bump clap from 4.5.18 to 4.5.19 by @dependabot in #1032
• [ISSUE #1035]🐛Fix clippy check error by @mxsm in #1036
• [ISSUE #1029]🚀Support order message consume for client🔥 by @mxsm in #1034
• [ISSUE #1037]Optimize DefaultMQPushConsumer by @mxsm in #1038
• Bump proc-macro2 from 1.0.86 to 1.0.87 by @dependabot in #1047
• Bump futures-util from 0.3.30 to 0.3.31 by @dependabot in #1046
• Bump futures from 0.3.30 to 0.3.31 by @dependabot in #1040
• Bump once_cell from 1.20.1 to 1.20.2 by @dependabot in #1044
• Bump sysinfo from 0.31.4 to 0.32.0 by @dependabot in #1039
• Bump clap from 4.5.19 to 4.5.20 by @dependabot in #1048
• [ISSUE #1049]Implement MessageUtil by @mxsm in #1050
• [ISSUE ##1011]Remove useless clippy annotations by @shadowsoy in #1051
• [ISSUE #1054]Use tokio Implement java CountDownLatch by @mxsm in #1055
• [ISSUE #1056]Optimize CountDownLatch⚡️ by @mxsm in #1057
• Bump proc-macro2 from 1.0.87 to 1.0.88 by @dependabot in #1059
• Bump uuid from 1.10.0 to 1.11.0 by @dependabot in #1058
• Bump serde_json from 1.0.128 to 1.0.129 by @dependabot in #1060
• [ISSUE ##1052] Support request code LOCK_BATCH_MQ(41) by @mxsm in #1061
• [ISSUE #1053] Support request code UNLOCK_BATCH_MQ(42) by @mxsm in #1062
• Bump serde_json from 1.0.129 to 1.0.130 by @dependabot in #1064
• Bump anyhow from 1.0.89 to 1.0.90 by @dependabot in #1063
• [ISSUE #1065]Add msrv in .clippy.toml by @ButterflyEffect1991 in #1066
• [ISSUE #1067] Supprot mq fault strategy by @mxsm in #1068
• Bump bytes from 1.7.2 to 1.8.0 by @dependabot in #1073
• Bump syn from 2.0.79 to 2.0.82 by @dependabot in #1072
• [ISSUE #1069]Add Shutdown struct by @mxsm in #1070
• Bump serde_json from 1.0.130 to 1.0.132 by @dependabot in #1071
• [ISSUE #1074]Optimize Shutdown by @mxsm in #1075
• [ISSUE #1076]PullMessageService and RebalanceService add shutdown method by @mxsm in #1077
• Bump proc-macro2 from 1.0.88 to 1.0.89 by @dependabot in #1083
• Bump tokio from 1.40.0 to 1.41.0 by @dependabot in #1082
• Bump anyhow from 1.0.90 to 1.0.91 by @dependabot in #1081
• Bump thiserror from 1.0.64 to 1.0.65 by @dependabot in #1080
• Bump serde from 1.0.210 to 1.0.213 by @dependabot in #1079
• Bump syn from 2.0.82 to 2.0.84 by @dependabot in #1085
• Bump config from 0.14.0 to 0.14.1 by @dependabot in #1084
• Bump regex from 1.11.0 to 1.11.1 by @dependabot in #1087
• Bump syn from 2.0.84 to 2.0.85 by @dependabot in #1086
• [ISSUE #1078]🚀Support send transaction message for client🍻 by @mxsm in #1088
• [ISSUE #1089]🔥Optimize api according to rust api-guidelines🎨 by @mxsm in #1090
• [ISSUE #1092] Add OperationResult struct by @Fly-cmd-ops in #1093
• Bump reqwest from 0.12.8 to 0.12.9 by @dependabot in #1095
• Bump serde from 1.0.213 to 1.0.214 by @dependabot in #1094
• [ISSUE #1091]🔥Support broker receive transaction message🚀 by @mxsm in #1096
• [ISSUE #1098]🚀Add ArcMut struct by @mxsm in #1099
• [ISSUE #1101] fix "subtract with overflow" bug for allocate_message_queue_averagely by @frankchen7788 in #1102
• Bump anyhow from 1.0.91 to 1.0.92 by @dependabot in #1105
• Bump syn from 2.0.85 to 2.0.86 by @dependabot in #1104
• Bump thiserror from 1.0.65 to 1.0.66 by @dependabot in #1103
• [ISSUE #1106]Fix When topic not create the client can not consume by @mxsm in #1108
• [ISSUE #1107]Replace ArcRefCellWrapper with ArcMut by @mxsm in #1109
• [ISSUE #1110] Enable Consumer logging by @rust-learn-now in #1111
• [ISSUE #1112]Optimize MessageTrait's methods signature by @mxsm in #1113
• Bump thiserror from 1.0.66 to 1.0.68 by @dependabot in #1117
• Bump anyhow from 1.0.92 to 1.0.93 by @dependabot in #1118
• Bump tokio from 1.41.0 to 1.41.1 by @dependabot in #1119
• Bump tempfile from 3.13.0 to 3.14.0 by @dependabot in #1120
• [ISSUE #1121]🧪Add test case for AccessChannel by @master-main-hub in #1122
• [ISSUE #1123]🧪Add test case for Validators by @main-master-hub in #1124
• [ISSUE #1125]🔊Implementing functionality similar to Java's LinkedBlockingQueue in Rust using Tokio🚀 by @mxsm in #1126
• [ISSUE #1127]🧪Add test case for BlockingQueue by @main-master-hub in #1128
• [ISSUE #1129]📝Add doc for BlockingQueue by @master-main-hub in #1130
• [ISSUE #1097]🚧Support broker receive transaction message-2🔥 by @mxsm in #1131
• [ISSUE #1134]🔥Remove BrokerConfig duplicate codes🔥 by @rust-learn-now in #1135
• Bump thiserror from 1.0.68 to 1.0.69 by @dependabot in #1138
• Bump serde from 1.0.214 to 1.0.215 by @dependabot in #1137
• [ISSUE #1132]⚡️Optimize std String with Cheetah String🔥 by @mxsm in #1139
• [ISSUE #1140]⚡️Enhanced the RequestHeaderCodec macro by @mxsm in #1141
• [ISSUE #1142]🔥Use CheetahString to replace std String🍻 by @mxsm in #1143
• [ISSUE #1144]Bump cheetah-string 0.1.2 to 0.1.4 by @rust-learn-now in #1145
• [ISSUE #1146]Update Github Actions CI by @shadowsoy in #1147
• [ISSUE #1148]Update codecov Github actions CI by @mxsm in #1149
• [ISSUE #1150]Use CheetahString to replace std String in MessageQueue by @Fly-cmd-ops in #1151
• [ISSUE #1152] Add test case for MessageQueue by @what-design in #1153
• [ISSUE #1154]🚀Optimize RemotingCommand method🎨 by @mxsm in #1155
• Bump clap from 4.5.20 to 4.5.21 by @dependabot in #1157
• Bump codecov/codecov-action from 4.0.1 to 4.6.0 by @dependabot in #1156
• [ISSUE #1158]Refactor message_utils#delete_property method by @TeslaRustor in #1159
• [ISSUE #1160]🔥Optimize ValidateTopicResult String with CheetahString by @mxsm in #1161
• [ISSUE #1163]📝Add rocketmq-rust roadmap by @mxsm in #1164
• [ISSUE #1165]📝Update README.md by @mxsm in #1166
• [ISSUE #1167]🎨Optimize RemotingCommand#with_remark method🎨 by @mxsm in #1168
• Bump codecov/codecov-action from 4.6.0 to 5.0.0 by @dependabot in #1170
• [ISSUE #1171]Fix test case TopicConfigAndMappingSerializeWrapper#topic_config_and_mapping_serialize_wrapper_getters error by @rust-learn-now in #1172
• Bump flate2 from 1.0.34 to 1.0.35 by @dependabot in #1169
• Bump codecov/codecov-action from 5.0.0 to 5.0.2 by @dependabot in #1175
• [ISSUE ##1176]📝Update Github actions CI by @rocketmq-rust-bot in #1177
• [ISSUE #1180]Fix cargo clippy -- -D warnings error by @mxsm in #1181
• [ISSUE #1173]🔥Optimize use CheetahString replace Std String🎨 by @mxsm in #1174
• [ISSUE #1182]🔨Add remove-label-on-approve.yml by @mxsm in #1183
• [ISSUE #1184]🔨Upate Github actions CI🔧 by @mxsm in #1185
• [ISSUE #1186]🔥Optimize MQClientAPIImpl method🚀 by @mxsm in #1187
• [ISSUE #1188]🔨Upate Github actions CI🔧 by @mxsm in #1189
• [ISSUE #1192] 🔨Upate Github actions CI🔧 by @mxsm in #1193
• [ISSUE #1190]🧪Add unit test for CMResult by @main-master-hub in #1191
• [ISSUE #1194]🔥Add doc for log.rs🚀 by @mxsm in #1195
• [ISSUE #1196]🔥Optimize CheetahString as method arg🎨 by @mxsm in #1197
• [ISSUE #1194]🔨Update package , publish script📝 by @mxsm in #1199
• [ISSUE #1200]⚡️Optimize CheetahString for rocketmq-broker and rocketmq-store🎨 by @mxsm in #1201
• [ISSUE #1202]🔨Upate Github actions CI🔧 by @mxsm in #1203
• [ISSUE #1204]🔨Update package , publish script by @mxsm in #1205
• [ISSUE #1207]🔥Rename rocketmq-client crate name to rocketmq-client-rust🐛 by @mxsm in #1208

New Contributors

• @flydream-ylgw made their first contribution in #444
• @yulanggongwu made their first contribution in #446
• @ButterflyEffect1991 made their first contribution in #478
• @dream-cloud-fly made their first contribution in #521
• @alax-cat made their first contribution in #716
• @847850277 made their first contribution in #807
• @note-art made their first contribution in #944
• @Fly-cmd-ops made their first contribution in #1093
• @frankchen7788 made their first contribution in #1102
• @rust-learn-now made their first contribution in #1111
• @master-main-hub made their first contribution in #1122
• @main-master-hub made their first contribution in #1124
• @what-design made their first contribution in #1153
• @rocketmq-rust-bot made their first contribution in #1177

Full Changelog