rocketmq-rust-all-0.8.0

Announcement: RocketMQ Rust 🔖v0.8.0 has been released

New Feature and improve performance

• ✨ Fix some bugs
• ⚡️ Optimize code performance
• 🚀 Add proxy mode
• 🚀 Add dashborad

What's Changed

• [ISSUE #4495]📝Update to Version 0.7.0 for Next-Stage Development by @mxsm in #4496
• [ISSUE #4498]♻️Refactor pull message processing to return RocketMQResult for improved error handling by @mxsm in #4499
• [ISSUE #4500]Refactor validation rules in refactor.yml to improve clarity and reduce redundancy by @mxsm in #4501
• [ISSUE #4503]🔧Update enhancement and feature request templates for improved clarity and structure by @mxsm in #4504
• [ISSUE #4505]♻️Refactor EndTransactionProcessor to return RocketMQResult for improved error handling by @mxsm in #4506
• [ISSUE #4507]♻️Refactor consumer management processor to return RocketMQResult for improved error handling by @mxsm in #4508
• [ISSUE #4465] BrokerRuntimeInner#message_store method to return an Option reference for improved safety by @EricZZZ in #4509
• [ISSUE #4511]♻️Refactor subscription group management to use Arc for improved memory efficiency and thread safety by @mxsm in #4512
• [ISSUE #4468] Remove GetMessageResult#release method by @EricZZZ in #4510
• [ISSUE #4513]♻️Refactor ConsumeMessageContext to use references for improved memory efficiency by @mxsm in #4514
• [ISSUE #4515]♻️Refactor update_order_topic_config to accept a reference for improved performance and implement topic configuration updates by @mxsm in #4516
• [ISSUE #4517]✨Add decode_str and decode_string methods to RemotingDeserializable trait for improved string handling by @mxsm in #4518
• Bump criterion from 0.8.0 to 0.8.1 by @dependabot[bot] in #4522
• Bump reqwest from 0.12.24 to 0.12.25 by @dependabot[bot] in #4520
• Bump local-ip-address from 0.6.5 to 0.6.6 by @dependabot[bot] in #4521
• Bump flume from 0.11.1 to 0.12.0 by @dependabot[bot] in #4523
• [ISSUE #4524]♻️Refactor file handling functions for improved error handling and code clarity by @mxsm in #4525
• [ISSUE #4526]✨Enhancement file handling functions to use RocketMQResult for error handling and improve path handling by @mxsm in #4527
• [ISSUE #4529]✨Enhancement load_data_version to use file_utils for improved file handling by @mxsm in #4530
• [ISSUE #4533]✨Improve offset update logging and delay level parsing in schedule_message_service by @mxsm in #4534
• [ISSUE #4535]🚀Implement graceful shutdown for ScheduleMessageService with task management by @mxsm in #4536
• [ISSUE #4537]♻️Refactor file reading logic to return an empty string for non-existent files instead of an error by @mxsm in #4538
• [ISSUE #4539]✨Add performance optimizations and new benchmarks for ScheduleMessageService by @mxsm in #4540
• [ISSUE #4541]Refactor file_to_string to handle non-existent files gracefully and improve error handling by @mxsm in #4542
• [ISSUE #4497] Update categories in Cargo.toml to reflect accurate classification by @EricZZZ in #4531
• [ISSUE #4502] [Feature🚀] Remove useless code from QueryMessageProcessor by @EricZZZ in #4532
• [ISSUE #4543]✨Update async handling for message processing functions across multiple modules by @mxsm in #4544
• [ISSUE #4528]✨Change hook_name return type from String to &'static str for improved performance by @WaterWhisperer in #4545
• [ISSUE #4519]✨Remove useless JsonSerializable trait by @WaterWhisperer in #4546
• [ISSUE #4548]✨Add comments for clarity in consumer_send_msg_back_request_header and send_message_processor by @mxsm in #4549
• [ISSUE #4547] [Enhancement✨] Change log level from info to debug for delay level parsing in ScheduleMessageService by @EricZZZ in #4551
• [ISSUE #4552]✨Enhance ReplyMessageProcessor with detailed documentation and improve error handling by @mxsm in #4553
• [ISSUE #4556]♻️Refactor TopicRequestHeader: streamline imports, enhance tests, and remove unused code by @mxsm in #4557
• [ISSUE #4559]✨Enhance IndexFile documentation: add detailed comments on structure, collision handling, and thread safety by @mxsm in #4560
• [ISSUE #4550]Remove useless commented code from file_to_string by @anshikasingh0705 in #4561
• [ISSUE #4562]✨Enhance IndexService: improve file loading, add index type support, and optimize file deletion logic by @mxsm in #4563
• [ISSUE #4554] [Enhancement✨] Change topic field in ViewMessageRequestHeader from CheetahString to Option for improved flexibility by @EricZZZ in #4564
• [ISSUE #4555] [Enhancement✨] Risks of optimizing method view_message_by_id in QueryMessageProcessor by @EricZZZ in #4565
• [ISSUE #4558] [Enhancement✨] Risks of optimizing method query_message in QueryMessageProcessor by @EricZZZ in #4566
• [ISSUE #4567]Remove unnecessary commented code in index_service.rs for cleaner readability by @mxsm in #4568
• [ISSUE #4570]✨Enhance query_assignment method in QueryAssignmentProcessor: add validation for request fields, improve logging, and implement unit tests for queue allocation strategies by @mxsm in #4571
• [ISSUE #4572]🚀Add support for additional request codes in admin_broker_processor and request_code modules by @mxsm in #4573
• [ISSUE #4138]🚀Implement RemappingStaticTopicSubCommand by @WaterWhisperer in #4574
• [ISSUE #4575]🚀Implement BoundaryType enum with serialization, deserialization, and parsing methods; add SearchOffsetRequestHeader struct with tests by @mxsm in #4576
• [ISSUE #4577]🚀Implement TopicRequestHeaderTrait for SearchOffsetRequestHeader with methods for managing topic and queue ID, and ensure safe handling of optional fields by @mxsm in #4578
• [ISSUE #4579]♻️Refactor request handling methods to return RocketMQResult for improved error handling and consistency across handlers by @mxsm in #4580
• [ISSUE #4581]✨Reduce the use of clone() by @WaterWhisperer in #4582
• Bump local-ip-address from 0.6.6 to 0.6.7 by @dependabot[bot] in #4583
• [ISSUE #4599]📝Update license comments by @mxsm in #4600
• [ISSUE #4602]🚀Add MessageRelatedHandler for handling message-related requests and integrate with AdminBrokerProcessor by @mxsm in #4603
• [ISSUE #4605]🚀Implement logic for retrieving queue offsets by timestamp with boundary checks in local file stores by @mxsm in #4606
• [ISSUE #4607]🚀Implement asynchronous request rewriting for static topics in MessageRelatedHandler by @mxsm in #4608
• [ISSUE #4585]✨Optimized GetMaxOffsetRequestHeader to implement TopicRequestHeaderTrait, which may cause panic by @WaterWhisperer in #4609
• [ISSUE #4611]🚀Timestamp handling in mapped files with atomic operations and add binary search for queue offsets by timestamp by @mxsm in #4612
• [ISSUE #4613]♻️Refactor binary search logic in queue offset retrieval by timestamp to improve boundary handling and return values by @mxsm in #4614
• [ISSUE #4615]🚀Implement cold data flow control services and related logic for managing consumer group thresholds and pull requests by @mxsm in #4616
• [ISSUE #4587]✨Optimized GetMinOffsetRequestHeader to implement TopicRequestHeaderTrait, which may cause panic by @WaterWhisperer in #4610
• [ISSUE #4617]🐛Update response code for outdated consumer filter data in pull message processor by @mxsm in #4618
• [ISSUE #4619]♻️Refactor PullMessageProcessor by removing unused ColdDataCgCtrService and optimizing write message lock documentation by @mxsm in #4620
• [ISSUE #4621]♻️Refactor PullMessageProcessor to improve subscription data handling and message filtering logic by @mxsm in #4622
• [ISSUE #4624]♻️Refactor PopReviveService to enhance request handling and error management by @mxsm in #4625
• [ISSUE #4626]🚀Add PopReviveMessageType enum for broker metrics representation by @mxsm in #4627
• [ISSUE #4623]🐛Fix the RocketMQ-Dashboard control panel does not support querying message details by message ID by @mxsm in #4631
• [ISSUE #4632]🚀Add producer_attr module to metrics for enhanced metric tracking by @mxsm in #4633
• [ISSUE #4634] 🚀Add InvocationStatus enum for metrics tracking by @mxsm in #4635
• [ISSUE #4636] 🚀Add PopMetricsManager for OpenTelemetry-based metrics tracking in RocketMQ by @mxsm in #4637
• [ISSUE #4639] 🚀Add MetricsExporterType enum for metrics export configuration by @mxsm in #4640
• [ISSUE #4641]🚀Add NopLongCounter implementation for OpenTelemetry metrics by @mxsm in #4642
• [ISSUE #4593]✨Optimized UpdateConsumerOffsetRequestHeader to implement TopicRequestHeaderTrait, which may cause panic by @WaterWhisperer in #4630
• [ISSUE #4589]✨Optimized QueryConsumerOffsetRequestHeader to implement TopicRequestHeaderTrait, which may cause panic by @WaterWhisperer in #4629
• [ISSUE #4643]🚀Add NopLongHistogram implementation for OpenTelemetry metrics by @mxsm in #4644
• [ISSUE #4646]🚀Add NopObservableLongGauge implementation for OpenTelemetry metrics by @mxsm in #4647
• [ISSUE #4648]🚀Add BrokerMetricsManager for comprehensive broker-level metrics management by @mxsm in #4649
• [ISSUE #4650]✨Increase retry intervals in auto-approve pull requests workflow by @mxsm in #4651
• [ISSUE #4652]🚀Add observability metrics for pop revive operations in pop_revive_service by @mxsm in #4653
• [ISSUE #4654]🧪Disable performance regression detection test temporarily by @mxsm in #4655
• [ISSUE #4656]♻️Refactor PopInflightMessageCounter to use DashMap for improved concurrency and readability by @mxsm in #4657
• [ISSUE #4588]✨Optimized PullMessageRequestHeader to implement TopicRequestHeaderTrait, which may cause panic by @WaterWhisperer in #4628
• [ISSUE #4658]♻️Refactor PopReviveService to use Arc and Arc for improved concurrency and thread safety by @mxsm in #4659
• [ISSUE #4660]✨Inflight request handling in PopReviveService for improved efficiency and readability by @mxsm in #4661
• [ISSUE #4662]✨Optimize PopReviveService some clone methods by @mxsm in #4663
• [ISSUE #4664]♻️Refactor PopBufferMergeService to use AtomicI64 for revive_queue_offset and improve garbage scanning logic by @mxsm in #4665
• [ISSUE #4666]✨Enhance PopBufferMergeService with improved error handling and graceful shutdown logic by @mxsm in #4667
• [ISSUE #4671]♻️Refactor PopMessageProcessor for improved message store handling and offset calculations by @mxsm in #4672
• [ISSUE #4601]🧪SearchOffsetResponseHeader add test case by @WaterWhisperer in #4670
• [ISSUE #4673] ✨Enhance StatsItem with atomic operations and sampling methods for improved concurrency and performance by @mxsm in #4674
• [ISSUE #4675]✨Enhance BrokerStatsManager with scheduled sampling tasks and improved stats management by @mxsm in #4676
• [ISSUE #4677]✨Enhance BrokerStatsManager with additional statistics methods and improved data handling by @mxsm in #4678
• [ISSUE #4591]✨Optimized SendMessageRequestHeaderV2 to implement TopicRequestHeaderTrait, which may cause panic by @WaterWhisperer in #4668
• [ISSUE #4594]✨Add #[required] and test case for GetEarliestMsgStoretimeResponseHeader by @WaterWhisperer in #4669
• [ISSUE #4682]♻️Refactor ConsumeQueueTrait and related implementations to replace ReferredIterator with a more generic Iterator type for improved flexibility by @mxsm in #4683
• [ISSUE #4684]✨Enhance CqExtUnit with improved size calculations, buffer read/write methods, and comprehensive tests by @mxsm in #4685
• [ISSUE #4584] [Enhancement✨] Remove useless code form get_max_offset_request_header.rs by @EricZZZ in #4680
• Bump reqwest from 0.12.25 to 0.12.26 by @dependabot[bot] in #4689
• Bump local-ip-address from 0.6.7 to 0.6.8 by @dependabot[bot] in #4690
• [ISSUE #4604]✨Make MessageRelatedHandler struct private to the modulefor better encapsulation by @WaterWhisperer in #4679
• [ISSUE #4691]♻️Refactor offset table access methods for improved mutability and performance by @mxsm in #4692
• [ISSUE #4693]🐛Fix buffer length calculations and simplify get method in consume queue by @mxsm in #4694
• [ISSUE #4697]🐛Fix RequestCode::GetTopicConfig get topic config painc by @mxsm in #4698
• [ISSUE #4592]✨Remove useless code from update_consumer_offset_header.rs by @WaterWhisperer in #4686
• [ISSUE #4701]♻️Refactor ProducerManager for improved thread safety and performance by @mxsm in #4702
• [ISSUE #4687]🧪Add test case for TopicRequestHeaderTrait implement in UpdateConsumerOffsetRequestHeader by @WaterWhisperer in #4688
• [ISSUE #4586] [Enhancement✨] Remove useless code from get_min_offset_request_header.rs by @EricZZZ in #4681
• [ISSUE #4696]🚀Implement RequestCode GetConsumerRunningInfo(307) by @WaterWhisperer in #4703
• [ISSUE #4595] [Enhancement✨] Remove useless code from get_consumer_listby_group_response_header.rs by @EricZZZ in #4705
• [ISSUE #4699] [Enhancement✨] Replace topic_config_and_queue_mapping encode with ? to avoid panic in TopicRequestHandler#get_topic_config by @EricZZZ in #4706
• [ISSUE #4695]🐛Fix get consume detail not show Client Info by @mxsm in #4707
• [ISSUE #4708]🐛Fix producer manager shutdown dead lock by @mxsm in #4709
• Refactor: Remove useless code from update_and_create_topic (fixes #4710) by @mihneapopesq in #4710
• [ISSUE #4712]♻️Refactor ConsumerManager to use DashMap for improved concurrency and performance by @mxsm in #4713
• [ISSUE #4714]🐛Fix rocketmq new dashboard not show Version mode and type by @mxsm in #4715
• [ISSUE #4718]🚀Add PollingInfoResponseHeader struct and related tests by @mxsm in #4719
• [ISSUE #4720]🚀Add PollingInfoRequestHeader struct for polling information requests by @mxsm in #4721
• [ISSUE #4723]🧪Add test case for PollingInfoRequestHeader struct by @WaterWhisperer in #4724
• [ISSUE #4725]🚀Add PollingInfoProcessor for handling polling information requests by @mxsm in #4726
• [ISSUE #4716]🧪Add test case for ConsumerConnection struct by @WaterWhisperer in #4722
• [ISSUE #4727]🚀Add PeekMessageRequestHeader for message peeking requests by @mxsm in #4728
• [ISSUE #4729]🚀Add PeekMessageProcessor for handling peek message requests by @mxsm in #4730
• [ISSUE #4732]♻️Refactor notification processor to improve topic name handling and streamline message queue checks by @mxsm in #4733
• [ISSUE #4734]♻️Refactor EndTransactionProcessor for improved error handling and validation logic by @mxsm in #4735
• [ISSUE #4736]Enhance EndTransactionProcessor with improved logging and metrics tracking for transaction commits and rollbacks by @mxsm in #4737
• [ISSUE #4731] [Test🧪] Add test case for PeekMessageRequestHeader struct by @EricZZZ in #4740
• [ISSUE #4738]♻️Refactor DefaultPullMessageResultHandler to enhance message processing and metrics recording by @mxsm in #4739
• [ISSUE #4741]♻️Refactor consumer management processor for improved request handling and error responses by @mxsm in #4742
• Refactor: remove useless code from get_all_topic_config_response_head… by @mihneapopesq in #4745
• [ISSUE #4717] [Enhancement✨] Replace body_data encode with ? to avoid panic in ConsumerRequestHandler#get_consumer_connection_list by @EricZZZ in #4743
• Refactor: remove useless code from broker_request.rs (fixes #4598) by @mihneapopesq in #4744
• Refactor/remove useless code 4596 by @mihneapopesq in #4746
• [ISSUE #4747]🚀Add RpcClientError type for improved error handling in RPC communications by @mxsm in #4748
• [ISSUE #4749]♻️Refactor RpcClientImpl implemention by @mxsm in #4750
• [ISSUE #4751]✨Add some helper methods for RpcClientError by @mxsm in #4752
• [ISSUE #4753]🚀Add heartbeat and data version management methods for broker communication by @mxsm in #4754
• [ISSUE #4755]🚀add AlterSyncStateSetRequestHeader struct by @mxsm in #4756
• [ISSUE #4758]🚀Add AlterSyncStateSetResponseHeader struct by @mxsm in #4759
• [ISSUE #4760] 🚀Add ApplyBrokerIdRequestHeader struct by @mxsm in #4761
• [ISSUE #4762]🚀Add ElectMasterRequestHeader struct by @mxsm in #4763
• [ISSUE #4764]🚀Add GetNextBrokerIdRequestHeader struct by @mxsm in #4765
• [ISSUE #4766]🚀Add GetReplicaInfoRequestHeader struct by @mxsm in #4767
• [ISSUE #4768]🚀Add GetReplicaInfoResponseHeader struct by @mxsm in #4769
• [ISSUE #4770]🚀Add RegisterBrokerToControllerRequestHeader struct by @mxsm in #4771
• [ISSUE #4780]🚀Add RegisterBrokerToControllerResponseHeader struct by @mxsm in #4782
• [ISSUE #4772]🧪Add test case for AlterSyncStateSetRequestHeader by @WaterWhisperer in #4786
• [ISSUE #4774]🧪Add test case for ApplyBrokerIdRequestHeader by @WaterWhisperer in #4788
• [ISSUE #4791]♻️Refactor RebalanceLockManager locking logic and add unit tests for try_lock functionality by @mxsm in #4792
• Bump clap_complete from 4.5.61 to 4.5.62 by @dependabot[bot] in #4794
• Bump tracing from 0.1.43 to 0.1.44 by @dependabot[bot] in #4795
• [ISSUE #4773]🧪Add test case for AlterSyncStateSetResponseHeader by @WaterWhisperer in #4787
• [ISSUE #4797]🚀Add ApplyBrokerIdResponseHeader struct by @mxsm in #4798
• [ISSUE #4799]🚀Add GetNextBrokerIdResponseHeader struct by @mxsm in #4800
• [ISSUE #4801]🚀Add ElectMasterResponseBody struct by @mxsm in #4802
• [ISSUE #4806]🚀Add controller interaction methods for broker management by @mxsm in #4807
• [ISSUE #4809]🚀Implement clean-up and management methods for consume queues by @mxsm in #4810
• Refactor: remove useless code from GetBrokerMemberGroupRequestHeader … by @mihneapopesq in #4785
• Removed useless code in check_transaction_state_request_header.rs fix… by @mihneapopesq in #4796
• [ISSUE #4811]♻️Refactor MappedFileQueue to use ArcSwap for lock-free access to mapped files by @mxsm in #4812
• Remove useless thiserror crate from rocketmq-client Cargo.toml by @mihneapopesq in #4814
• [ISSUE #4815]🚀Add GetConsumerStatusBody struct for consumer status response handling by @mxsm in #4816
• [ISSUE #4819]✨Do not generate CodeRabbit Plan Mode for the ISSUE by @mxsm in #4820
• [ISSUE #4823]🚀Add MessageQueueForC struct for C++ client compatibility by @mxsm in #4824
• [ISSUE #4825]🚀Add GetConsumerStatusRequestHeader for consumer status retrieval by @mxsm in #4826
• [ISSUE #4817]🚀Add ResetOffsetBody struct for reset consumer offset response handling by @mxsm in #4818
• [ISSUE #4827]🚀Implement consumer status retrieval and offset reset functionality by @mxsm in #4830
• [ISSUE #4775]🧪Add test case for ElectMasterRequestHeader by @WaterWhisperer in #4821
• [ISSUE #4776]🧪Add test case for GetNextBrokerIdRequestHeader by @WaterWhisperer in #4822
• [ISSUE #4831]🚀Add rocketmq-auth module with initial implementation and dependencies by @mxsm in #4832
• [ISSUE #4833]🚀Add rocketmq-proxy module with initial implementation and dependencies by @mxsm in #4834
• [ISSUE #4777]🧪Add test case for GetReplicaInfoRequestHeader by @WaterWhisperer in #4828
• [ISSUE #4835]♻️Refactor client metadata handling to use Arc for shared ownership by @mxsm in #4836
• [ISSUE #4778]🧪Add test case for GetReplicaInfoResponseHeader by @WaterWhisperer in #4829
• [ISSUE #4757]✨Add header License for broker.rs by @WaterWhisperer in #4783
• [ISSUE #4840]🚀Add unified error handling system for RocketMQ operations by @mxsm in #4841
• [ISSUE #4847]♻️Refactor MQClientManager to use DashMap for concurrent access and improve performance by @mxsm in #4848
• [ISSUE #4849]♻️Refactor message trait bounds to remove unnecessary Clone trait requirement by @mxsm in #4850
• [ISSUE #4779]🧪Add test case for RegisterBrokerToControllerRequestHeader by @WaterWhisperer in #4837
• [ISSUE #4851]♻️Refactor send_with_timeout method to accept generic message types implementing MessageTrait by @mxsm in #4852
• [ISSUE #4863]♻️Refactor compressor handling to use static references for improved performance and memory efficiency by @mxsm in #4864
• [ISSUE#4839]🚀Implement RequestCode GetProducerConnectionList(204) by @Lori-Shu in #4846
• [ISSUE #4865]♻️Refactor producer_request_handler to streamline connection retrieval and improve error handling for non-existent producer groups by @mxsm in #4866
• [ISSUE #4781]🧪Add test case for RegisterBrokerToControllerResponseHeader by @WaterWhisperer in #4838
• [ISSUE #4869]🚀Add BrokerLifecycleListener trait and helper module for broker lifecycle management by @mxsm in #4870
• [ISSUE #4871]🚀Add BrokerIdentityInfo struct for broker heartbeat identity management and integrate cheetah-string dependency by @mxsm in #4872
• [ISSUE #4874]🚀Add BrokerLiveInfo struct for managing broker liveness and metadata in heartbeat module by @mxsm in #4875
• [ISSUE #4881]🚀Add BrokerLiveInfoGetter trait for retrieving broker liveness info and expose broker_live_info module by @mxsm in #4882
• [ISSUE #4887]🚀Add BrokerValidPredicate trait for validating broker identity and integrate broker_valid_predicate module into helper by @mxsm in #4888
• [ISSUE #4889]🚀Add ElectPolicy trait for master broker election and introduce elect module structure by @mxsm in #4890
• [ISSUE #4803]🧪Add test case for ApplyBrokerIdResponseHeader struct by @WaterWhisperer in #4873
• [ISSUE #4891]🚀Add event module with EventType enum for standardized event identification and handling by @mxsm in #4892
• [ISSUE #4894]🚀Add event_message module with EventMessage trait for unified event type retrieval by @mxsm in #4895
• [ISSUE #4896]🚀Add alter_sync_state_set_event module with AlterSyncStateSetEvent struct for sync state set change events by @mxsm in #4897
• [ISSUE #4898]🚀Add apply_broker_id_event module with ApplyBrokerIdEvent struct for broker ID application events by @mxsm in #4899
• [ISSUE #4903]🚀Add clean_broker_data_event module with CleanBrokerDataEvent struct for broker data cleanup events by @mxsm in #4904
• [ISSUE #4906]🚀Add elect_master_event module with ElectMasterEvent struct for master election events by @mxsm in #4907
• [ISSUE #4909]🚀Add update_broker_address_event module with UpdateBrokerAddressEvent struct for broker address update events by @mxsm in #4911
• [ISSUE #4912]🚀Add controller_result module with ControllerResult struct for encapsulating controller operation results by @mxsm in #4913
• [ISSUE #4804]🧪Add test case for GetNextBrokerIdResponseHeader struct by @WaterWhisperer in #4878
• [ISSUE #4805]🧪Add test case for ElectMasterResponseBody struct by @WaterWhisperer in #4879
• [ISSUE #4808]🧪Add test case for SyncStateSet struct by @WaterWhisperer in #4880
• [ISSUE #4842]♻️ Refactor lazy_static with std::sync::LazyLock in client_config.rs by @EricZZZ in #4884
• [ISSUE #4843] [Refactor♻️] Refactor lazy_static with std::sync::LazyLock in message_client_id_setter.rs by @EricZZZ in #4885
• [ISSUE #4853]♻️Refactor send_with_callback_timeout to accept generic message types implementing MessageTrait by @WaterWhisperer in #4914
• [ISSUE #4917]🚀Add controller_metrics_constant module with metrics constants and helper enums for controller metrics by @mxsm in #4918
• [ISSUE #4910]🧪Add test case for UpdateBrokerAddressEvent struct by @undali in #4916
• [ISSUE #4919]🚀Add broker_close_channel_request module with BrokerCloseChannelRequest struct and integrate into task module by @mxsm in #4920
• [ISSUE #4921]🚀Add broker_close_channel_response module with BrokerCloseChannelResponse struct and expose in task module by @mxsm in #4922
• [ISSUE #4924]🚀Add sync_state_info module with SyncStateInfo struct for managing broker sync state and epochs by @mxsm in #4925
• Refactor: replace lazy_static with OnceLock for SYSTEM_GROUP_SET (fix… by @mihneapopesq in #4883
• [ISSUE #4926]🚀Add check_not_active_broker_request module with CheckNotActiveBrokerRequest struct and integrate into task module by @mxsm in #4927
• [ISSUE #4844 #4845] [Refactor♻️] Refactor sendSmartMsg lazy_static with std::sync::LazyLock, INIT_REMOTING_VERSION lazy_static with std::sync::OnceLock in mq_client_api_impl.rs by @EricZZZ in #4886
• [ISSUE #4929]🚀Add broker_replica_info module with BrokerReplicaInfo struct and expose in manager module by @mxsm in #4930
• Bump reqwest from 0.12.26 to 0.12.28 by @dependabot[bot] in #4934
• Bump serde_json from 1.0.145 to 1.0.146 by @dependabot[bot] in #4933
• [ISSUE #4854]♻️Refactor send_message_in_transaction to accept generic message types implementing MessageTrait by @WaterWhisperer in #4915
• [ISSUE #4935]🚀Add check_not_active_broker_response module with CheckNotActiveBrokerResponse struct and integrate into task module by @mxsm in #4936
• [ISSUE #4937]🚀Add get_broker_live_info_request module with GetBrokerLiveInfoRequest struct and expose in task module by @mxsm in #4938
• [ISSUE #4941]🚀Add get_broker_live_info_response module with GetBrokerLiveInfoResponse struct and expose in task module by @mxsm in #4942
• [ISSUE #4939]🚀Add DefaultElectPolicy implementation and expose in elect::policy module by @mxsm in #4940
• [ISSUE #4943]🚀Add raft_broker_heartbeat_event_request module with RaftBrokerHeartBeatEventRequest struct and expose in task module by @mxsm in #4944
• [ISSUE #4946]🚀Add get_sync_state_data_request and raft_broker_heartbeat_event_response modules with corresponding structs and expose in task module by @mxsm in #4947
• Refactor: replace String with CheetahString in AlterSyncStateSetEvent… by @mihneapopesq in #4923
• [ISSUE #4948]🚀Add event_serializer module by @mxsm in #4949
• [ISSUE #4950]🚀Add controller_bootstrap binary entry point and register in Cargo.toml by @mxsm in #4951
• [ISSUE #4855]♻️Refactor send_batch to accept generic message types implementing MessageTrait by @WaterWhisperer in #4931
• Test: add test cases for SyncStateInfo (fixes #4928) by @mihneapopesq in #4932
• [ISSUE #4952]🚀Add controller module and BrokerHousekeepingService implementation by @mxsm in #4953
• [ISSUE #4954]✨Enhance controller_bootstrap with logger initialization, version info, and improved startup output by @mxsm in #4955
• [ISSUE #4957]use println! to display logo instead of info! by @ismailoksuz in #4959
• [ISSUE #4960]🚀Add command module with Args struct for CLI argument parsing using clap by @mxsm in #4961
• Bump arc-swap from 1.7.1 to 1.8.0 by @dependabot[bot] in #4963
• [ISSUE #4958] Update naming from "remoting_server" to "name server" in namesrv_bootstrap_server.rs by @PhysShell in #4962
• [ISSUE #4964]🚀Add controller and configuration modules for RocketMQ controller management by @mxsm in #4965
• [ISSUE #4966]🚀Integrate OpenRaft and tonic gRPC; add protobuf definitions and build script for controller and raft services by @mxsm in #4967
• [ISSUE #4968]🚀Add OpenRaft type definitions and aliases for RocketMQ controller by @mxsm in #4969
• [ISSUE #4970]🚀Add OpenRaft log store, state machine, and storage modules for RocketMQ controller by @mxsm in #4971
• [ISSUE #4972]🚀Add OpenRaft network and node management modules by @mxsm in #4973
• [ISSUE #4974]🚀Add OpenRaft gRPC network client/server, protobuf definitions, and integration tests; refactor network module for gRPC support by @mxsm in #4975
• [ISSUE #4980]🔧Update raft dependency to use latest master branch from tikv/raft-rs repository by @mxsm in #4981
• Bump tempfile from 3.23.0 to 3.24.0 by @dependabot[bot] in #4982
• Bump prost-types from 0.13.5 to 0.14.1 by @dependabot[bot] in #4985
• Bump tonic-reflection from 0.12.3 to 0.14.2 by @dependabot[bot] in #4984
• [ISSUE #4989]✨Bump tonic, prost, and related dependencies to 0.14; switch build to tonic-prost-build by @mxsm in #4990
• [ISSUE #4991]🚀Implement gRPC streaming for OpenRaft snapshot install; add snapshot functionality tests by @mxsm in #4992
• [ISSUE #4856]♻️Refactor send_batch_with_timeout to accept generic message types implementing MessageTrait by @WaterWhisperer in #4976
• [ISSUE #4993]🧪Add test case for openraft by @mxsm in #4994
• Bump serde_json from 1.0.146 to 1.0.147 by @dependabot[bot] in #4986
• [ISSUE #4995]🚀Add controller processor framework and manager modules; expose new controller components by @mxsm in #4996
• [ISSUE #4997]🚀Introduce broker heartbeat management framework; add trait, default implementation, and lifecycle listener interface by @mxsm in #4998
• [ISSUE #4999]♻️Refactor BrokerReplicaInfo to use DashMap for broker_id_info; improve concurrency and update serialization/deserialization logic by @mxsm in #5000
• [ISSUE #5001]🚀Introduce ReplicasInfoManager for broker replica state management with concurrency support by @mxsm in #5002
• [ISSUE #4857]♻️Refactor send_batch_to_queue to accept generic messagetypes implementing MessageTrait by @WaterWhisperer in #4977
• [ISSUE #4858]♻️Refactor send_batch_to_queue_with_timeout to accept generic message types implementing MessageTrait by @WaterWhisperer in #4978
• [ISSUE #4859]♻️Refactor send_batch_with_callback to accept generic message types implementing MessageTrait by @WaterWhisperer in #4979
• [ISSUE #5006]♻️Refactor CI workflow: unify system dependencies, streamline caching, and simplify build/test matrix for all platforms by @mxsm in #5007
• [ISSUE #5010]♻️Refactor CI workflow: restrict 'Test (all features)' s… by @mxsm in #5011
• [ISSUE #5008] 🚀ControllerMetricsManager for comprehensive controller metrics with OpenTelemetry support by @mxsm in #5009
• [ISSUE #4860]♻️Refactor send_batch_with_callback_timeout to accept generic message types implementing MessageTrait by @WaterWhisperer in #5003
• [ISSUE #5012]🚀Implement controller manager: modularize lifecycle, add heartbeat/metrics integration, and provide usage examples by @mxsm in #5013
• [ISSUE #5015]🚀Add AuthConfig struct by @mxsm in #5016
• [ISSUE #4861]♻️Refactor send_batch_to_queue_with_callback to accept generic message types implementing MessageTrait by @WaterWhisperer in #5004
• [ISSUE #5018]🚀Add PlainAccessConfig struct with serialization support and integrate module structure by @mxsm in #5019
• [ISSUE #5017]add unit test for AuthConfig default implementation by @TyagarajN in #5020
• [ISSUE #5022]🚀Add AclConfig struct with support for global white addresses and plain access configs by @mxsm in #5024
• [ISSUE #5025]🚀Add PlainAccessData struct with versioning and change detection support by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5026
• [ISSUE #5028]🚀Add PlainAccessResource struct with access control fields and utility methods by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5029
• [ISSUE #5031]🚀Add PlainPermissionManager with ACL file discovery, YAML parsing, and config aggregation by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5032
• [ISSUE #4862]♻️Refactor send_batch_to_queue_with_callback_timeout to accept generic message types implementing MessageTrait by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5005
• [ISSUE #5033]🚀Add authentication module with AuthenticationContext for extensible context management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5034
• [ISSUE #5038]✨producer modules to remove unused import of Message from message_single by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5039
• [ISSUE #5036]♻️Refactor AuthenticationContext into trait and introduce BaseAuthenticationContext struct for extensible context management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5037
• [ISSUE #5042]🚀Add DefaultAuthenticationContext struct with username, content, and signature fields for extensible authentication context management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5043
• [ISSUE #5045]🚀Add enums module with subject_type enum for extensible subject classification in authentication by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5046
• [ISSUE #5048]🚀Add user_status enum with serialization support for user status management in authentication by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5050
• [ISSUE #5051]🚀Add user_type enum with serialization support for user type management in authentication by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5052
• [ISSUE #5054]🚀Add model module with Subject trait for extensible subject abstraction in authentication by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5055
• [ISSUE #5057]🚀Add user module with User struct implementing Subject trait for extensible user management in authentication by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5058
• [ISSUE #5061]🚀Add strategy module with AuthorizationStrategy trait for extensible authorization evaluation in authentication by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5062
• [ISSUE #4945]Add test case for RaftBrokerHeartBeatEventRequest by @mihneapopesq in https://github.com/mxsm/rocketmq-rust/pull/5014
• [ISSUE #5063]🚀Add authorization module with context and strategy submodules and migrate related files for modular authorization management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5064
• [ISSUE #5060]♻️Replace lazy_static! with std::sync::LazyLock and remove lazy_static dependency from rocketmq-remoting by @K-dash in https://github.com/mxsm/rocketmq-rust/pull/5065
• [ISSUE #5056]♻️Replace lazy_static with LazyLock in broker_config by @K-dash in https://github.com/mxsm/rocketmq-rust/pull/5066
• Refactor/issue5068 replace lazy static with lazy lock by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5069
• [ISSUE #4876]🧪Add test case for BrokerIdentityInfo in controller crate by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5067
• [ISSUE #5071]Replace lazy_static! with LazyLock by @cnaples79 in https://github.com/mxsm/rocketmq-rust/pull/5070
• [ISSUE #5072]🚀Add enums module and Decision enum for modular authorization decision management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5073
• [ISSUE #5075]🚀Add policy_type module with PolicyType enum for modular policy type management in authorization by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5077
• [ISSUE #5078]🚀Add model module for foundational data structures in authorization by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5079
• [ISSUE #5080]🚀Add resource module with ResourceType enum for modular resource type management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5082
• [ISSUE #5083]🚀Add environment module with Environment struct for IP-based authorization context and matching by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5084
• [ISSUE #5085]🚀Add action module with Action enum for modular action type management in authorization by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5086
• [ISSUE #5088]🚀Add resource_pattern module with ResourcePattern enum for flexible resource pattern matching and serialization by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5089
• [ISSUE #5093]🚀Add resource module with Resource struct for flexible resource type, name, and pattern management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5094
• [ISSUE #5097]🚀Add policy_entry module with PolicyEntry struct for comprehensive policy rule management and matching by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5098
• [ISSUE #5091]♻️Replace lazy_static with LazyLock in delivery by @K-dash in https://github.com/mxsm/rocketmq-rust/pull/5095
• [ISSUE #5092]♻️Replace lazy_static with LazyLock in trace_view by @K-dash in https://github.com/mxsm/rocketmq-rust/pull/5096
• [ISSUE #5101]🚀Add policy module with Policy struct for flexible policy management and entry operations by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5102
• [ISSUE #4867]🧪Add test case for GetProducerConnectionListRequestHeader by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5099
• [ISSUE #5103]🚀Add acl module with Acl struct for flexible subject-policy management and policy operations by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5104
• [ISSUE #4877]🧪Add test case for BrokerLiveInfo in controller crate by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5100
• [ISSUE #4893]🧪Add test case for EventType in event_type.rs by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5105
• [ISSUE #5109]🚀Refactor controller config to use shared ControllerConfig from rocketmq-common; migrate node-specific fields and builder methods, update usages across crate by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5110
• Added tests for action.rs by @ChrisAB in https://github.com/mxsm/rocketmq-rust/pull/5112
• [ISSUE #4900]🧪Add test case for AlterSyncStateSetEvent by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5106
• [ISSUE #4902]🧪Add test case for ApplyBrokerIdEvent by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5107
• [ISSUE #5113]🚀Add default authorization context and provider abstraction; expose model and provider modules; update dependencies for async and error handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5114
• [ISSUE #5115]🚀Add base authorization context abstraction; extend default authorization context with channel ID support and builder methods by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5116
• Feature/issue 5090 add test case for resource pattern by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5111
• [ISSUE #5118]🚀Add authorization metadata provider abstraction and example; expose authorization module; improve topic publish info API by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5119
• [ISSUE #5121]🚀Add default authorization provider implementation with chain-of-responsibility pattern and tests by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5122
• [ISSUE #5124]🚀Add local authorization metadata provider with RocksDB-based ACL storage, in-memory caching, and tests by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5126
• [ISSUE #5049]🧪Add test case for UserStatus by @sukurajima-mai in https://github.com/mxsm/rocketmq-rust/pull/5125
• [ISSUE #5135]🚀Add AuthorizationStrategy trait by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5140
• [ISSUE #5136]🚀Add StatefulAuthorizationStrategy by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5145
• [ISSUE #5137]🚀Add StatelessAuthorizationStrategy by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5146
• This PR replaces the trace dispatcher TODO with an explicit unimplemented!() macro, as discussed in issue #5123. This makes the behavior explicit and avoids leaving a silent TODO in the producer startup path. by @AnantShukla-Git-Hub in https://github.com/mxsm/rocketmq-rust/pull/5139
• Added test case for ResourceType in rocketmq-common crate by @Ranish-Garg in https://github.com/mxsm/rocketmq-rust/pull/5147
• Set default use_route_info_manager_v2 to true in NamesrvConfig by @YashIIT0909 in https://github.com/mxsm/rocketmq-rust/pull/5148
• [ISSUE #4905]🧪Add test case for CleanBrokerDataEvent by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5108
• [Test🧪] Add test case for SubjectType (closes 5047) by @sukurajima-mai in https://github.com/mxsm/rocketmq-rust/pull/5127
• [ISSUE #5153]Add NotInitialized error variant to unified error enum by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5154
• [Test🧪] Add test code for UserType (closes #5053) by @sukurajima-mai in https://github.com/mxsm/rocketmq-rust/pull/5129
• Bump serde_json from 1.0.147 to 1.0.148 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5162
• Bump clap_complete from 4.5.62 to 4.5.63 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5164
• Bump proc-macro2 from 1.0.103 to 1.0.104 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5163
• [Refactor♻️] Replacing logger info! macro with println! by @sam-paiva in https://github.com/mxsm/rocketmq-rust/pull/5161
• [ISSUE #4908]🧪Add test case for ElectMasterEvent by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5128
• [ISSUE #5035] Add tests for BaseAuthenticationContext by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5149
• Return borrowed reference from produce_accumulator getter by @Animesh-Parashar in https://github.com/mxsm/rocketmq-rust/pull/5160
• [ISSUE #5023]🧪Add test case for AclConfig by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5132
• [ISSUE #5027]🧪Add test case for PlainAccessData by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5138
• [ISSUE #5174]🚀Add AuthorizationMetadataManager for high-level ACL management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5175
• [ISSUE #5030]🧪Add test case for PlainAccessResource by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5141
• Return borrowed reference from trace_dispatcher by @Animesh-Parashar in https://github.com/mxsm/rocketmq-rust/pull/5159
• [ISSUE #5176]🚀Add AuthorizationMetadataManagerImpl for ACL management and validation by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5177
• [ISSUE #5181]♻️Refactor authentication context modules and update license headers by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5182
• [ISSUE #5076] Add test cases for PolicyType by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5151
• [ISSUE #5183]🚀Add chain of responsibility pattern implementation with Handler and HandlerChain modules by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5184
• [ISSUE #5189]🚀Add AuthError module and integrate authentication error handling into unified error system by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5190
• [ISSUE #5192]🚀Add authentication context builder modules and implement DefaultAuthenticationContextBuilder for gRPC and Remoting requests by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5193
• fix: #set_rpc_hook to always wrap dispatcher in Some and remove Option by @YashIIT0909 in https://github.com/mxsm/rocketmq-rust/pull/5150
• [ISSUE #5194]♻️Refactor ControllerRequestProcessor to return Option for request handlers and implement process_request delegation by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5195
• [ISSUE #5059]🧪Add test case for User in rocketmq-auth crate by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5179
• [ISSUE #5155] Added error handling in send_direct for unintialized defaultMQProducer by @Animesh-Parashar in https://github.com/mxsm/rocketmq-rust/pull/5185
• [ISSUE #5198]🚀Add controller error module with unified error types and constructors by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5199
• [ISSUE #5142] Refactor DefaultMQProducer#set_trace_dispatcher to alwa… by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5152
• [ISSUE #5200] 🚀Add Controller trait abstraction, mock implementation, and doc comments; refactor error.rs to re-export error types by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5201
• [ISSUE #5120]♻️Refactor update_topic_publish_info to accept generic topic parameter in producer interfaces by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5197
• [ISSUE #5196] chore(deps): bump base64 to 0.22.1 and tonic to 0.14.2 by @varundeepsaini in https://github.com/mxsm/rocketmq-rust/pull/5206
• [ISSUE #5205]🚀Apply rustfmt for improved readability and consistency,Update rustfmt.toml with new formatting rules by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5207
• [ISSUE #5074]🧪Add test case for Decision by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5180
• [ISSUE #5210]✨style: format update_topic_publish_info signatures to single line for consistency by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5211
• [ISSUE #5208]♻️Refactor Cargo.toml for improved readability: align fields, group dependencies, and format entries consistently by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5209
• Bump clap_complete from 4.5.63 to 4.5.64 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5222
• [ISSUE #5191]🧪Add test case for AuthError by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5220
• Bump reqwest from 0.12.28 to 0.13.1 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5223
• [ISSUE #5225]Refactor rocketmq-auth Cargo.toml: align fields, group dependencies, and format entries for consistency by @yaoliang888 in https://github.com/mxsm/rocketmq-rust/pull/5226
• refactor: change return type of MQProducer::send_to_queue to RocketMQ::Result<Option> by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5224
• [ISSUE #5243]✨Reformat rocketmq main Cargo.toml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5244
• [ISSUE #5245]✨Optimize ci.yml to solve the disk space full problem by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5246
• Reformat rocketmq-tools crate Cargo.toml use taplo 5241 by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5249
• [ISSUE #5247]✨Remove unused import of tracing::warn from default_authentication_context_builder.rs by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5248
• [ISSUE #5250]✨Optimize clippy checks for ci.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5251
• [ISSUE #5254]🚀Add OpenRaftController by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5255
• [ISSUE #5044]🧪Add test case for DefaultAuthenticationContext by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5178
• [Enhancement✨]:Reformat rocketmq-runtime and rocketmq-store by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5256
• [ISSUE #5257]🚀Add RaftRsController based on raft-rs by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5258
• [ISSUE #5259]🚀Add RaftController wrapper by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5260
• [ISSUE #5165]✨Add error handlingor uninitialized DefaultMQProducer in fetch_publish_message_queues by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5252
• Bump syn from 2.0.111 to 2.0.112 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5221
• [ISSUE #5227]✨Reformat rocketmq-broker crate Cargo.toml use taplo by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5261
• [ISSUE #5156] Added error handling in send_by_accumulator for unintialized defaultMQProducer by @Animesh-Parashar in https://github.com/mxsm/rocketmq-rust/pull/5204
• [ISSUE #5264]🚀Add pluggable authentication strategy framework with allow-all implementation by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5265
• [ISSUE #5188]♻️Refactor MQConsumer trait to remove MQAdmin inheritance by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5253
• [ISSUE #5232] reformat rocketmq-error Cargo.toml with taplo by @srpvpn in https://github.com/mxsm/rocketmq-rust/pull/5273
• [ISSUE #5262]⬆️Bump ratatui to 0.30.0 and crossterm to 0.29.0 in dependencies in rocketmq-tui crate by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5267
• [ISSUE #5263]📝Fix typo in Cargo.toml comment for JSON support in rock… by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5272
• [ISSUE #5279]🚀Add AuthenticationProvider trait and re-exports for pluggable authentication support by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5280
• [ISSUE #5281]🚀Add AuthenticationMetadataProvider trait and re-exports for user management support by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5282
• [ISSUE #5228]✨Reformat rocketmq-cli crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5278
• [ISSUE #5283]🚀Add DefaultAuthenticationProvider implementation and re-exports for authentication framework by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5284
• [ISSUE #5218]🧪Add test case for SendStatus by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5275
• [ISSUE #5242]:Reformat rocketmq-tui's Cargo.toml by @srpvpn in https://github.com/mxsm/rocketmq-rust/pull/5277
• [ISSUE #5216]✨Add error handling or uninitialized DefaultMQProducer i… by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5271
• [ISSUE #5166]✨Add error handlingor uninitialized DefaultMQProducer in send_with_timeout by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5266
• [ISSUE #5285]🚀Add LocalAuthenticationMetadataProvider with in-memory user management and tests by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5286
• Change SendMessageProcessor request code log level from info to debug for less verbose output - 5219 by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5270
• [ISSUE #5186]🧪Add test case for OffsetWrapper in rocketmq-remoting crate by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5268
• [ISSUE #5287]🚀Add AbstractAuthenticationStrategy and BaseAuthenticationStrategy implementations with factory trait by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5288
• [ISSUE #5187]🧪Add test case for TopicOffset in rocketmq-remoting crate by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5269
• [ISSUE #5217]🧪Add test case for SendResult by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5274
• [ISSUE #5291]🚀Add StatefulAuthenticationStrategy with caching support for authentication results by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5292
• [ISSUE #5293]🚀Add StatelessAuthenticationStrategy for independent request authentication by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5294
• [ISSUE #5295]🚀Add AuthenticationEvaluator for coordinating authentication strategies by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5296
• [ISSUE #5299]🚀Implement authentication handler chain and default authentication handler with HMAC-SHA1 signature verification by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5300
• [ISSUE #5289]🧪Add test case for ClusterInfo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5301
• [ISSUE #5303]🚀Add AuthenticationMetadataManager for user management and metadata operations by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5304
• [ISSUE #5305]📝Add NOTICE file for RocketMQ Rust project with copyright and attribution by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5306
• [ISSUE #5167]✨Add error handlingor uninitialized DefaultMQProducer in send_with_callback_timeout by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5297
• [ISSUE #5290]🧪Add test case for LockBatchRequestBody by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5302
• [ISSUE #5307]🚀Implement AuthenticationMetadataManager for user management and authorization metadata by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5308
• [ISSUE #5309]✨Normalize license headers across source files by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5310
• [ISSUE #5229]✨Reformat rocketmq-client crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5298
• [ISSUE #5311]✨Correct copyright year in Apache 2.0 license headers by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5312
• [ISSUE #5316]🚀Add Command Line Interface for RocketMQ Controller with configuration support by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5317
• [ISSUE #5318]🚀Enhance RocketMQ Controller Bootstrap with command-line argument parsing and configuration loading by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5319
• [ISSUE #5320]📝Update README with installation instructions and configuration examples for RocketMQ Controller by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5321
• [ISSUE #5323]♻️Refactor broker shutdown handling for improved clarity and error messaging by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5324
• [ISSUE #5230]✨Reformat rocketmq-common crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5314
• [ISSUE #5168]✨Add error handlingor uninitialized DefaultMQProducer in send_oneway by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5313
• doc 5315 - added documentation for main.rs in rocketmq-example by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5322
• doc 5235: changed from name server to broker in main readme by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5330
• [ISSUE #5338]♻️Refactor broker shutdown handling for improved concurrency and clarity by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5339
• [ISSUE #5340]✨Simplify the Broker's startup and shutdown processes by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5341
• [ISSUE #5327]✨Improve topic_queue_mapping_clean_service_mut accessor … by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5332
• [Enhancement✨] Change Producer::send return type to Option in RocketMQResult by @youneedgreg in https://github.com/mxsm/rocketmq-rust/pull/5342
• [ISSUE #5343]✨Optimize auto-comment-pr.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5344
• [ISSUE #5345]✨Update sync-issue-labels.yml to trigger on pull request creation only by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5346
• [ISSUE #5170]✨Add error handlingor uninitialized DefaultMQProducer in send_to_queue_with_timeout by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5349
• [ISSUE #5347]🚀Implement ControllerManager and related components for improved state management and error handling-1 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5348
• [ISSUE #5353]🚀Add AuthenticationFactory for centralized creation and caching of authentication components by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5354
• [ISSUE #5231]✨Reformat rocketmq-controller crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5350
• [ISSUE #5355]♻️Refactor heartbeat manager handling to use ArcMut for improved concurrency and clarity by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5356
• [ISSUE #5337]✨Simplify ArcMut cloning in LatencyFaultTolerance initialization in MQFaultStrategy by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5352
• [ISSUE #5357]🚀Add AuthorizationEvaluator and related components for enhanced authorization decision-making by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5358
• refactor(broker): remove useless code from BrokerRuntimeInner #5336 by @vishaal2002 in https://github.com/mxsm/rocketmq-rust/pull/5359
• [ISSUE #5360]🚀Implement ControllerServerRequestProcessor for enhanced request handling and processing flexibility by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5361
• [ISSUE #5329]✨Remove useless code from broker_bootstrap.rs by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5331
• [ISSUE #5326]✨Improve broker_stats accessor to return Option<&T> in BrokerRuntimeInner by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5351
• [ISSUE #5364]✨Enhance ClientConfig with new trace and metadata pagination settings by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5365
• [ISSUE #5233]✨Reformat rocketmq-example crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5367
• Bump clap from 4.5.53 to 4.5.54 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5380
• [ISSUE #5171]✨Add error handlingor uninitialized DefaultMQProducer in send_to_queue_with_callback_timeout by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5366
• eng-5373 removed tool error file by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5379
• [ISSUE #5362]✨Remove lazy_static crate dependence from rocketmq-client crate Cargo.toml by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5369
• [ISSUE #5382]🚀Integrate BrokerHousekeepingService with ControllerManager for enhanced management and lifecycle handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5383
• [ISSUE #5386]Add FilterError module for enhanced error handling in filter operations by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5387
• [ISSUE #5389]♻️Refactor BitsArray to include error handling and improve bitwise operations by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5390
• [ISSUE #5384]🚀Implement ACL-based authorization handler and chain for modular access control by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5385
• [ISSUE #5328]✨Improve pull_request_hold_service_mut accessor to return Option<&T> in BrokerRuntimeInner by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5368
• [ISSUE #5392]✨Enhance BloomFilter implementation with detailed documentation and error handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5393
• [ISSUE #5234]✨Reformat rocketmq-filter crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5397
• [ISSUE #5173]✨Add error handlingor uninitialized DefaultMQProducer in send_with_selector by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5396
• [ISSUE #5403]✨Add FilterError handling and constructors for improved error management in filter operations by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5404
• [ISSUE #5405]✨Refactor BitsArray and BloomFilter to use RocketMQResult for improved error handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5406
• [ISSUE #5407]♻️Refactor MessageBatch to improve message handling and add iterator support by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5408
• [ISSUE #5363]✨Remove lazy_static crate dependence from rocketmq-broker crate Cargo.toml by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5400
• [ISSUE #5413]Implement Processor Registry V2 with core and plugin architecture for enhanced request handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5414
• [ISSUE #5333]✨Improve replicas_manager accessor to return Option<&T> in BrokerRuntimeInner by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5398
• fix：Add error handlingor uninitialized TransactionMQProducer in send_… by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5418
• [ISSUE #5372]🚀Add error variant for missing required message property… by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5417
• feat-5370: added a function to get the local time based on IANA time zone specified in env by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5416
• [ISSUE #5419]✨Add local timezone support using iana-time-zone crate for improved logging by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5420
• [ISSUE #5421]🚀Implement MessageEvaluationContext for efficient expression evaluation with enhanced serialization support by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5422
• [ISSUE #5425]🚀Add boolean expression evaluation traits and implementations for message filtering by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5426
• [ISSUE #5395]🚀Implement conversion of FilterContext to Rust based on Java version's FilterContext by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5399
• [ISSUE #5427]🚀Add BinaryExpression trait for message filtering to support complex expressions by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5429
• [ISSUE #5431]🚀Implement BaseBinaryExpression and enhance Display traits for expression evaluation by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5432
• [ISSUE #5436]🚀Add filter module with core Filter trait and factory for message filtering by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5437
• [ISSUE #5438]🚀Implement SQL-92 expression filter for RocketMQ message filtering by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5439
• [ISSUE #5440]🚀 Add FilterFactory for managing filter implementations with dynamic registration and retrieval by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5441
• [ISSUE #5212]✨Add error handlingor uninitialized DefaultMQProducer in request_to_queue_with_callback by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5428
• [ISSUE #5409] - common(filter): convert Type enum from Rust by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5444
• [ISSUE #5381]✨Update MQProducer send_to_queue_with_timeout to return an optional SendResult for improved error handling by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5401
• [ISSUE #5236]✨Reformat rocketmq-namesrv crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5433
• [ISSUE #5235]✨Reformat rocketmq-macros crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5402
• [ISSUE #5391]🧪Add test case for BitsArray by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5450
• [ISSUE #5334]✨ Improve replicas_manager_mut accessor to return Option<&T> in BrokerRuntimeInner by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5434
• Feat-5410: add op and operand in filter by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5442
• [ISSUE #5375]🧪Add test case for ProtocolError by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5445
• [ISSUE #5376]🧪Add test case for RpcClientError by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5446
• [ISSUE #5377]🧪Add test case for SerializationError by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5447
• [ISSUE #5378]🧪Add test case for ToolsError by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5448
• build: add Docker support by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5435
• [ISSUE #5388]🧪Add test case for FilterError by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5449
• [ISSUE #5172]Add error handlingor uninitialized DefaultMQProducer in send_oneway_to_queue by @bv-saketha-rama in https://github.com/mxsm/rocketmq-rust/pull/5462
• [ISSUE #5423]🚀Add an EmptyEvaluationContext struct based on Java code by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5452
• [ISSUE #5394]🧪Add test case for ExpressionType by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5451
• [ISSUE #5424]🚀Add UnaryType enumeration to rocketmq-filter crate (wit… by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5453
• [ISSUE #5213]✨Add error handlingor uninitialized DefaultMQProducer in request_to_queue by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5457
• [ISSUE #5237]✨Reformat rocketmq-proxy crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5458
• Bump tokio from 1.48.0 to 1.49.0 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5469
• Bump iana-time-zone from 0.1.63 to 0.1.64 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5476
• Bump libc from 0.2.178 to 0.2.179 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5475
• Add filter_type module to filter.rs in rocketmq-common crate by @vineethwilson15 in https://github.com/mxsm/rocketmq-rust/pull/5467
• [ISSUE #5335]✨Improve pull_request_hold_service accessor to return Option<&T> in BrokerRuntimeInner by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5459
• Bump tokio-util from 0.7.17 to 0.7.18 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5470
• Bump syn from 2.0.112 to 2.0.113 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5473
• [ISSUE #5455]✨Update of_type method to return ExpressionType::SQL92 in SQL-92 expression filter in filter_sql_filter.rs by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5463
• test-5374: tests added for network error by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5468
• [ISSUE #5214][ISSUE #5215]✨Add error handlingor uninitialized Default… by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5466
• Bump tokio-stream from 0.1.17 to 0.1.18 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5472
• [ISSUE #5477]⬆️Bump cheetah-string to version 1.0.1 and add simd feature by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5478
• [ISSUE #5412]🚀Based on the Java version Operator, converted to Rust and placed in rocketmq-common by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5465
• [ISSUE #5238]✨Reformat rocketmq-remoting crate Cargo.toml use taplo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5460
• [ISSUE #5371]✨Update DefaultMQProducerImpl#send_with_selector_timeout return type of send method to Option by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5461
• [ISSUE #5040]⬆️Update raft and openraft dependencies to specific commit revisions in Cargo.toml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5481
• [ISSUE #5430]📝Add a prompt in CONTRIBUTING that use taplo to format TOML if the Cargo.toml configuration modified by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5479
• [ISSUE #5483]🧪Add test case for ControllerError by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5484
• [ISSUE #5443] - common(producer): replace unwrap with proper error handling by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5482
• Bump serde_json from 1.0.148 to 1.0.149 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5508
• Bump tokio-test from 0.4.4 to 0.4.5 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5509
• Bump url from 2.5.7 to 2.5.8 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5510
• [ISSUE #5493] - client(producer): replace unwrap with proper error handling by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5512
• [ISSUE #5485]📝Update documentation for message type parameter in mq_producer.rs by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5500
• Bump quote from 1.0.42 to 1.0.43 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5511
• [ISSUE #5487]✨Add error handlingor uninitialized DefaultMQProducer in send_with_selector_timeout by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5501
• Bump proc-macro2 from 1.0.104 to 1.0.105 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5507
• [ISSUE #5488]✨Add error handlingor uninitialized DefaultMQProducer in send_with_selector_callback by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5502
• [ISSUE #5495]✨Add error handlingor uninitialized DefaultMQProducer in… by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5505
• [ISSUE #5517]♻️Refactor controller-related code for improved clarity and consistency by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5518
• [ISSUE #5489]✨Add error handlingor uninitialized DefaultMQProducer in send_with_selector_callback_timeout by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5503
• [ISSUE #5519]✨Enhance configuration handling and logging in RocketMQ Name Server by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5520
• [ISSUE #5521]✨Add example configuration and feature test scripts for RocketMQ Name Server by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5522
• [ISSUE #5523]📝Update README.md with improved usage instructions and configuration examples for RocketMQ Name Server by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5524
• [ISSUE #5490] - fix error handling in send_oneway_with_selector by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5514
• [ISSUE #5492] - fix error handling in send_batch_with_timeout by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5515
• [ISSUE #5494] - fix error handling in send_batch_to_queue_with_timeout by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5513
• [ISSUE #5525]♻️Refactor controller to remove RocketMQRuntime dependency and use ControllerConfig instead by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5526
• [ISSUE #5528]🚀Implement graceful shutdown and thread-safe state management for OpenRaft controller by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5529
• [ISSUE #5527] Update default controller listen port to 60109 by @LED-0102 in https://github.com/mxsm/rocketmq-rust/pull/5530
• [ISSUE #5531]♻️Refactor controllers to use ArcMut for mutable access to RaftController by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5532
• [ISSUE #5533]✨Enhance logging in ClientRequestProcessor by adding debug level for request code by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5546
• Bump clap_complete from 4.5.64 to 4.5.65 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5552
• [ISSUE #5496][ISSUE #5497]✨Add error handlingor uninitialized Default… by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5506
• [ISSUE #5491] - fix error handling in send_message_in_transaction by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5516
• [ISSUE #5555]✨Enhance broker startup process with improved argument validation and configuration handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5556
• enh-5498: removed unwrap and added RocketMQError by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5551
• [ISSUE #5557]📝Update README with enhanced usage instructions and configuration details for RocketMQ Broker by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5558
• [ISSUE #5559]📝Revamp README.md for improved clarity and engagement, enhancing project overview, features, and documentation links by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5560
• enh-5499:removed unwrap and added an error by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5550
• [ISSUE #5548] - remove unused code from produce_accumulator.rs by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5561
• [ISSUE #5562]📝Update README.md to enhance visual appeal and navigation with badge links for key sections by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5563
• Bump syn from 2.0.113 to 2.0.114 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5553
• [ISSUE #5565]📝Update README.md to standardize badge links with consistent styling for improved visual coherence by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5566
• [ISSUE #5569]📝Update README.md to remove unnecessary style attributes from badge links for improved readability by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5570
• [ISSUE #5571]📝Update README.md by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5572
• [ISSUE #5157] - fix error handling for uninitialized DefaultMQProducer in start by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5567
• refactor: Added inline annotation to clone_client_config method by @vishaal2002 in https://github.com/mxsm/rocketmq-rust/pull/5574
• Bump libc from 0.2.179 to 0.2.180 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5573
• [ISSUE #5486]✨Update MQProducer send_with_timeout method to return Op… by @leonprietobailo in https://github.com/mxsm/rocketmq-rust/pull/5504
• [ISSUE#5535] Implement BrokerHeartbeat Request Handler by @Lori-Shu in https://github.com/mxsm/rocketmq-rust/pull/5547
• [Feature🚀] Implement GetControllerConfig Request Handler by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5554
• [ISSUE #5578]🚀ProduceAccumulator to enhance batch processing and add synchronization features by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5579
• [ISSUE #5580]♻️Refactor ProduceAccumulator to use Tokio's Mutex for better async handling and improve batch processing logic by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5581
• [ISSUE #5577]✨Update MQProducer::send_with_selector method to return Option for improved error handling by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5585
• [ISSUE #5583]♻️Refactor ProduceAccumulator to use DashMap for concurrent batch processing and improve performance by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5584
• [ISSUE #5537]🚀Implement ControllerApplyBrokerId Request Handler by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5582
• [ISSUE #5599]♻️Refactor ProduceAccumulator to use Arc for currently_hold_size and improve async batch processing logic by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5600
• [ISSUE #5602]🚀DefaultMqProducer to enhance end transaction hook registration and implement graceful shutdown methods by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5603
• [ISSUE #5606]♻️Refactor DefaultMQProducer to replace RwLock with DashMap for improved concurrent access and performance by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5607
• [ISSUE #5608]🚀Add concurrent optimization benchmark to validate performance improvements and reduce overhead in DefaultMQProducer by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5609
• [ISSUE #5610]🚀Implement comprehensive shutdown procedure for MQClientInstance to ensure graceful termination and resource cleanup by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5611
• [ISSUE #5612]✨Enhance MQClientInstance shutdown process and introduce ScheduledTaskManager for improved task scheduling and management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5613
• [ISSUE #5615]🚀Enhance PullMessageService with improved error handling, graceful shutdown, and task execution features by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5616
• [ISSUE #5601]add comprehensive test cases for CommunicationMode (#5601) by @preettrank53 in https://github.com/mxsm/rocketmq-rust/pull/5614
• feat: Implement ControllerGetMetadataInfo Request Handler (#5539) by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5586
• refactor: remove repeated as_mut().unwrap() from default_mq_producer:… by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5618
• [ISSUE #5619]✨Enhance RebalanceService with dynamic configuration and improved error handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5620
• [ISSUE#5594] feat(tools): Implement updateTopicList command for batch Topic operations by @Lori-Shu in https://github.com/mxsm/rocketmq-rust/pull/5605
• Add test case for TopicPublishInfo (#5627) by @Varad-VK in https://github.com/mxsm/rocketmq-rust/pull/5630
• [ISSUE #5631]🚀feat: Add benchmarks and tests for ThreadLocalIndex optimization by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5632
• [ISSUE #5538] - Implement ControllerElectMaster Request Handler by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5564
• feat:5541-added the code for get replica info in controller and open raft by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5629
• [ISSUE #5634]♻️Refactor: Update ServiceDetector to support async detection and improve topic selection logic by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5635
• [ISSUE #5643]🐛Remove performance assertions from ThreadLocalIndex tests to reduce flakiness by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5644
• [Enhancement✨] Remove useless code from topic_route_data.rs by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5642
• [Enhancement✨] Remove async_sender_runtime and default_async_sender_runtime from DefaultMQProducerImpl by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5633
• Test/communication mode 5601 by @preettrank53 in https://github.com/mxsm/rocketmq-rust/pull/5639
• [ISSUE #5636]✨Add #[inline] for DefaultMQProducer's methods by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5641
• Test/find broker result 5604 by @preettrank53 in https://github.com/mxsm/rocketmq-rust/pull/5617
• [ISSUE #5575]✨Fix DefaultMQProducer set_default_mqproducer_impl to use ArcMut::clone for proper reference counting by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5640
• [ISSUE #5667]✨Enhance DefaultMQProducer with atomic state management, improved hook registration, and refined error handling during message sending by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5668
• Feature/issue 5624 implement controller command get controller meta data by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5654
• Bump colored from 3.0.0 to 3.1.1 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5696
• Bump chrono from 0.4.42 to 0.4.43 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5695
• Bump flate2 from 1.1.7 to 1.1.8 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5687
• Bump prost from 0.14.1 to 0.14.3 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5686
• Bump time from 0.3.44 to 0.3.45 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5692
• [ISSUE #5698]✨Clean up comments in bootstrap and route info manager files for clarity by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5699
• [Refactor♻️] Replace Lazy with std::sync::LazyLock and remove once create by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5681
• Bump local-ip-address from 0.6.8 to 0.6.9 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5691
• [ISSUE #5704]✨Update criterion dependency to version 0.8.1 and clean up benchmark imports by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5705
• [ISSUE #5706]📝Simplify benchmark documentation in produce_accumulator_benchmark.rs by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5707
• [ISSUE #5621]🚀Implement Controller Command: Clean Broker Metadata (cleanBrokerMetadata) by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5638
• [ISSUE#5545] Implement UpdateControllerConfig Request Handler by @Lori-Shu in https://github.com/mxsm/rocketmq-rust/pull/5682
• [Refactor♻️] Change default_mqproducer_impl_inner to use WeakArcMut for improved memory management by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5680
• [ISSUE #5703]🧪Add test case for UnaryType by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5708
• [ISSUE #5710]✨Enhance BrokerLiveInfo with remote address and channel ID, and update related methods for improved broker management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5711
• [ISSUE #5712]🚀Add common constants module for improved code readability and maintainability by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5713
• [ISSUE #5714]🚀Add cold data control module with accumulator and timestamp tracking by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5715
• [ISSUE #5701/#5702]🧪Add test case for BrokerUnregistration and RouteManagerConfig in types.rs by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5709
• [ISSUE #5717]🚀Add consistent hashing module with node trait for distributed load balancing by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5718
• [ISSUE #5723]🚀Add hash function trait for consistent hashing implementation by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5724
• [ISSUE #5725]🚀Add virtual node implementation for consistent hashing by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5726
• [ISSUE #5728]🚀Add consistent hash router implementation with virtual nodes for improved key distribution by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5729
• [ISSUE #5690]📝Add license header to topic_commands in rocketmq-tools crate by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5727
• [ISSUE #5623]🚀Implement Controller Command: Get Controller Config (getControllerConfig) by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5684
• [ISSUE #5733]🚀Add ReceiptHandle module for consumer message acknowledgment by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5734
• [ISSUE #5735]🚀Refactor JavaStringHasher to use UTF-16 encoding in hash_str method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5736
• [ISSUE #5648]🚀Implement DeleteSubscriptionGroupCommand for removing consumer groups by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5689
• feat:5625 added command for update controller config by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5697
• [ISSUE #5738]✨Enhance Message struct with new constructors for zero-copy and body slice options by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5739
• [ISSUE #5740]♻️Refactor put_user_property method for improved error handling and deprecate CommonError type by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5741
• [ISSUE #5743]🚀Add get_property_ref method to message structs for improved property access by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5744
• implement handle_get_next_broker_id for broker ID allocation by @aditya-rajpurohit in https://github.com/mxsm/rocketmq-rust/pull/5683
• Bump thiserror from 2.0.17 to 2.0.18 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5747
• Bump prost-types from 0.14.1 to 0.14.3 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5748
• feat: implement UpdateSubGroupSubCommand (#5653) by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5679
• [ISSUE #5716]🧪Add test case for AccAndTimeStamp by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5737
• [ISSUE #5753]♻️Refactor HttpTinyClient to support async HTTP requests and improve validation methods by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5754
• [ISSUE #5755]✨Add create_correlation_id_simple method for compact UUID generation by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5756
• [ISSUE #5757]♻️Refactor latency fault tolerance implementation for improved readability and performance by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5758
• feat: Add MessageQueueAssignment tests by @gbart0198 in https://github.com/mxsm/rocketmq-rust/pull/5759
• [ISSUE #5763]♻️Refactor topic type in default_mq_producer_impl for improved clarity and consistency by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5764
• [Enhancement✨] update MessageTrait get_compressed_body_mut method signature to return an Option<&mut Bytes> by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5762
• [ISSUE #5719]🧪Add test case for GetConsumerStatusBody by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5760
• [ISSUE #5765]♻️Refactor transaction management in MQ producer for improved error handling and clarity by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5766
• [ISSUE #5767]🚀Implement HeartbeatV2 protocol with fingerprint optimization and add related tests by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5768
• [ISSUE #5769]✨Add enable_concurrent_heartbeat configuration and implement concurrent heartbeat sending for improved performance by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5770
• [ISSUE #5771]🐛Fix client startup sometimes fails to connect to NameServer by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5772
• [ISSUE #5773]♻️Refactor MQ client instance to use DashMap for improved concurrency and performance by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5774
• feat: implement UpdateAclSubCommand (#5665) by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/5694
• [Feature🚀] Add get_keys_ref method to MessageTrait trait for improved tag access by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/5775
• [ISSUE #5777]♻️Refactor MQ client instance initialization for improved structure and clarity by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5778
• [ISSUE #5779]♻️Refactor MessageRequest trait to include into_any method for improved type downcasting by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5780
• [ISSUE #5781]♻️Refactor ConsumeMessageConcurrentlyService by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5782
• [ISSUE #5783]♻️Refactor ConsumeMessageOrderlyService for improved task management and shutdown handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5784
• [ISSUE #5721]🧪Add test case for SendMessageResponseHeader by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5785
• [ISSUE #5786]♻️Refactor ConsumeMessagePopConcurrentlyService for improved shutdown handling and task management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5787
• [ISSUE #5790]♻️Refactor ConsumeMessagePopConcurrentlyService to enhance concurrency management and task handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5791
• [ISSUE #5793]♻️Refactor ConsumeMessagePopOrderlyService to improve task management and shutdown handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5794
• [ISSUE #5796]♻️Refactor ConsumeMessagePopOrderlyService and ConsumeRequest for improved task management and concurrency handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5797
• refactor(consumer_impl): Remove the unnecessary code by @ruthwik-01 in https://github.com/mxsm/rocketmq-rust/pull/5795
• Bump proc-macro2 from 1.0.105 to 1.0.106 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5798
• [ISSUE #5761]📝Clean up redundant documentation comments to improve readability by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5788
• [ISSUE #5730]🚀Convert the DBMsgConstants, FIleReadaheadMode, HAProxyConstants class to Rust code by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5789
• [ISSUE #5799]🚀Add SessionCredentials module for managing access keys and security tokens by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5800
• [ISSUE #5803]🚀Add GetBrokerLiteInfoResponseBody struct for broker lite information handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5804
• [ISSUE #5806]🚀Add GetParentTopicInfoResponseBody struct for parent topic information handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5807
• [ISSUE #5809]🚀Add ConsumeByWho struct for tracking consumption groups and related metadata by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5810
• [ISSUE #5813]🚀Add GetLiteClientInfoResponseBody struct for lite client information handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5814
• [ISSUE #5816]🚀Add GetLiteGroupInfoResponseBody struct for lite group information handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5817
• [ISSUE #5542] Implement ControllerGetSyncStateData Request Handler by @gomnitrix in https://github.com/mxsm/rocketmq-rust/pull/5820
• [ISSUE #5821]🚀Add ClientGroup struct for managing client group information by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5822
• [ISSUE #5824]🚀Add GetLiteTopicInfoResponseBody struct for lite topic information handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5825
• [ISSUE #5801]🧪Add test case for SessionCredentials by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5827
• [ISSUE #5805]🧪Add test case for GetBrokerLiteInfoResponseBody by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5828
• [ISSUE #5831]🚀Add TopicGroup struct for managing topic group information by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5832
• [ISSUE #5834]🚀Add LiteSubscriptionAction enum for managing subscription actions in lite mode by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5835
• [ISSUE #5837]🚀Add OffsetOption and OffsetOptionType for flexible message queue offset seeking by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5838
• [ISSUE #5840]🚀Add LiteLagInfo struct for managing lightweight lag information in message queues by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5841
• [ISSUE #5843]🚀Add LiteSubscription struct for managing lightweight subscription information by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5844
• [ISSUE #5846]🐛Fix test_error_handling_timeout test case occasionally fails by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5847
• [ISSUE #5808]🧪Add test case for GetParentTopicInfoResponseBody by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5829
• [ISSUE #5848]🚀Add LiteSubscriptionDTO struct for managing lightweight subscription data by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5849
• [ISSUE #5851]🚀Add utility functions for lightweight topic management in message queues by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5852
• [ISSUE #5811]🧪Add test case for ConsumeByWho by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5830
• [ISSUE #5853]📝Update README-zh_cn.md by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5854
• [ISSUE #5860]🚀Refactor the official website using the Docusaurus web framework by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5861
• [ISSUE #5862]🐛Remove npm cache configuration from deploy.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5863
• [ISSUE #5864]🐛Update .gitignore to exclude package-lock.json except for rocketmq-website by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5865
• [ISSUE #5866]🚀Add announcement banner for RocketMQ-Rust v0.7.0 release and enhance homepage visuals by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5867
• [ISSUE #5868]🐛Fix clippy error by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5869
• [ISSUE #5870]🚀Add author information and update release notes structure by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5871
• [ISSUE #5872]🚀Update Quick Start Guide and project structure documentation for clarity and consistency by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5873
• [ISSUE #5823]🧪Add test case for ClientGroup by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5859
• [ISSUE #5815]🧪Add test case for GetLiteClientInfoResponseBody by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5856
• [ISSUE #5874]🚀Update development guide to reflect Rust nightly toolchain and enhance IDE setup instructions by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5875
• [ISSUE #5876]✨Enhance coding standards documentation for clarity and guidance on best practices by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5877
• [ISSUE #5818]🧪Add test case for GetLiteGroupInfoResponseBody by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5857
• [ISSUE #5878]🚀Add BrokerOperatorResult struct and tools module for broker operations by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5879
• [ISSUE #5880]🚀Add MessageTrack struct and TrackType enum for message tracking functionality by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5881
• [ISSUE #5882]🚀Implement lite pull topic management functions in admin extension by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5883
• [ISSUE #5819]🧪Add test case for LiteLagInfo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5858
• [ISSUE #5885]📝Update pull request template to correct issue reference formatting by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5886
• [ISSUE #5887]✨Enhance navbar styling with animated title and improved link effects by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5888
• [ISSUE #5889]✨Revamp author page with enhanced styling, detailed introduction, and expanded project information by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5890
• [ISSUE #5891]✨Enhance author page with improved layout, detailed introduction, and updated contact information by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5892
• [ISSUE #5893]📝Enhance layout and styling with new contributing section, improved feature animations, and updated resource links by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5894
• [ISSUE #5895]📝Update overview.md with contributing guidelines in Chinese, enhancing clarity for new contributors by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5896
• [ISSUE #5897]📝Add comprehensive development guide in Chinese, detailing environment setup, project structure, and testing strategies by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5898
• [ISSUE #5899]📝Translate sidebar labels and add coding standards document in Chinese by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5900
• [ISSUE #5901]✨Update favicon to SVG format for improved scalability and visual quality by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5902
• [ISSUE #5903]✨Remove unused dependencies by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5904
• [ISSUE #5907]🚀Add initial implementation of RocketMQ Dashboard GUI by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5908
• [ISSUE #5826]🧪Add test case for GetLiteTopicInfoResponseBody by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5905
• [ISSUE #5833]🧪Add test case for TopicGroup by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5906
• Bump core-graphics from 0.24.0 to 0.25.0 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5913
• Bump moka from 0.12.12 to 0.12.13 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5911
• Bump uuid from 1.19.0 to 1.20.0 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5912
• [ISSUE #5909]✨Enhance RocketMQ Dashboard with SVG icon support and improved sidebar layout by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5910
• [ISSUE #5917]🚀Implement Nameserver view component and enhance DashboardView with active page management by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5918
• [ISSUE #5919]🚀Add Cluster view component and integrate it into the DashboardView by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5920
• [ISSUE #5921]🚀Add Topic Management view component and integrate it into the DashboardView by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5922
• [ISSUE #5923]🚀Add Consumer Management view component and integrate it into the DashboardView by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5924
• Bump quote from 1.0.43 to 1.0.44 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5855
• Bump sysinfo from 0.37.2 to 0.38.0 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5914
• [ISSUE #5926]🚀Add Producer Management view component and integrate it into the DashboardView by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5927
• Bump time from 0.3.45 to 0.3.46 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5915
• Bump clap from 4.5.54 to 4.5.55 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5932
• [ISSUE #5925]✨Add cargo-shear CI check to detect unused dependencies by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5928
• [ISSUE #5836]🧪Add test case for LiteSubscriptionAction by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5929
• [ISSUE #5845]🧪Add test case for LiteSubscription by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5930
• [ISSUE #5933]🚀Add Message Query view component and integrate it into the DashboardView by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5934
• [ISSUE #5850]🧪Add test case for LiteSubscriptionDTO by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5931
• [ISSUE #5939]🧹Remove unused cargo-binstall and cargo-shear installation steps from CI configuration by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5940
• [ISSUE #5935]📝Update rocketmq-rust logo by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5936
• [ISSUE #5941]🧹Remove useless resources by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5942
• Bump tonic-prost from 0.14.2 to 0.14.3 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5943
• Bump tonic from 0.14.2 to 0.14.3 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5945
• Bump iana-time-zone from 0.1.64 to 0.1.65 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5946
• Bump tonic-prost-build from 0.14.2 to 0.14.3 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5944
• [ISSUE #5839]🧪Add test case for offset_option.rs by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5948
• [ISSUE#5646] Implement ConsumerStatusSubCommand for querying consumer internal data structure by @Lori-Shu in https://github.com/mxsm/rocketmq-rust/pull/5949
• Bump clap from 4.5.55 to 4.5.56 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5950
• [ISSUE #5951]♻️Refactor rockectmq-dashboard crate by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5952
• [ISSUE #5953]🧪Update tests to handle 503 response gracefully in http_tiny_client by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5954
• [ISSUE #5955]🚀Add initial implementation of rocketmq-admin-core module with CLI commands and formatters by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5956
• [ISSUE #5957]🚀Rename rocketmq-tui to rocketmq-admin-tui and update dependencies in Cargo files by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5958
• [ISSUE #5959]🚀Rename rocketmq-cli to rocketmq-store-inspect and update dependencies in Cargo files by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5960
• [ISSUE #5961]📝Update Docusaurus configuration for improved site settings and structure by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5962
• [ISSUE #5963]📝Update Algolia configuration with new appId, apiKey, and indexName for improved search functionality by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5964
• [ISSUE #5647]🚀Implement ConsumerSubCommand for querying consumer connection and status by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5965
• [ISSUE #5655]🚀Implement CopyAcls Command for ACL Replication by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5966
• [ISSUE #5967]♻️Refactor message queue locking and unlocking methods to be asynchronous and improve error handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5968
• Bump local-ip-address from 0.6.9 to 0.6.10 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/5969
• [ISSUE #5970]♻️Remove RocketMQRuntime instance from MQClientInstance and replace with tokio::spawn for asynchronous task handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5971
• [ISSUE #5972]♻️Refactor rebalance implementation for improved error handling and logging by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5973
• [ISSUE #5974]♻️Refactor ProcessQueue structure for improved performance and clarity by consolidating atomic fields and enhancing message handling logic by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5975
• update user sub command with related code by @albertbolt1 in https://github.com/mxsm/rocketmq-rust/pull/5977
• [ISSUE #5979]♻️Refactor Message creation and handling to utilize builder pattern for improved clarity and consistency by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5980
• [ISSUE #5656]🚀Implement CopyUsers Command for User Replication by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5978
• [ISSUE #5981]🚀Add new message types and refactor message handling for improved structure and clarity by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5982
• [ISSUE #5983]📝Rename version files for consistency and update release date by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5984
• [ISSUE #5985]📝RocketMQ Rust Release 🔖v0.7.0 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5986
• [ISSUE #5987]📝Add authors file and update release notes links for consistency by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5988
• [ISSUE #5992]📝Update CI configuration to ignore specific paths for push and pull request events by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5993
• [ISSUE #5994]📝Add GitHub Actions workflow for website deployment checks by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5995
• [ISSUE #5989][Enhancement✨] Add License header for user_converter.rs by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/5999
• [ISSUE #5996]📝Update author role from Owner to Maintainer in author.md by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/5997
• [ISSUE #5657]🚀Implement CreateAcl Command for RocketMQ ACL 2.0 Management by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/5998
• [ISSUE #6000]📝Remove 'rocketmq-dashboard' from CI paths to ignore for push and pull request events by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6001
• [ISSUE #6002]📝Add RocketMQ Rust new logo by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6003
• [ISSUE #6007]📝Update favicon from SVG to ICO format in docusaurus.config.ts by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6008
• [ISSUE #5976][Refactor♻️] Rename MessageTrait getters to idiomatic Rust naming by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6009
• [ISSUE #5658]🚀Implement CreateUser Command for RocketMQ User Management by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6006
• [Enhancement✨] Remove useless code from MQClientInstance by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/6010
• [ISSUE #6004]📝Update Cargo.toml and Cargo.lock for rocketmq-dashboard-gpui project configuration and dependencies by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6012
• Bump arc-swap from 1.8.0 to 1.8.1 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6016
• Bump bytemuck from 1.24.0 to 1.25.0 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6015
• [ISSUE #6013]📝Update Cargo.toml for project configuration and dependencies by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6014
• [ISSUE #5812][Test🧪] Add test case for CreateTopicListRequestBody by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6019
• [ISSUE #6018]🚀Initialize rocketmq-rust-dashboard-tauri by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6020
• [ISSUE #5884][Enhancement✨] Deprecate BrokerOperatorResult, MessageTrack, and TrackType structs due to relocation to rocketmq_common by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6017
• [ISSUE #6021]Add initial components and layout for the dashboard, including API service and theme hooks by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6022
• [ISSUE #6024]✨Update CI configuration to include paths for rocketmq-dashboard-gpui and rocketmq-dashboard-tauri by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6025
• feat: implement ListUsersSubCommand (#5664) by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/6011
• [ISSUE #6028]🐛fix: handle 503 response in timeout test for http_tiny_client by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6030
• [ISSUE #5659]🚀Implement DeleteAcl Command for ACL Entry Removal by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6023
• [ISSUE #6026]Add CI configuration for rocketmq-dashboard-tauri with frontend and Rust checks by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6027
• [ISSUE #5660]🚀Implement DeleteUser Command for User Account Removal by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6029
• Bump clap from 4.5.56 to 4.5.57 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6043
• Bump flate2 from 1.1.8 to 1.1.9 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6045
• Bump bytes from 1.11.0 to 1.11.1 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6044
• chore: add Apache 2.0 license headers to rocketmq-dashboard-tauri by @niveshdandyan in https://github.com/mxsm/rocketmq-rust/pull/6034
• [ISSUE #5742][Enhancement✨] Add #[inline] to the default implementations of methods in MessageTrait by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6038
• [ISSUE #5751][Test🧪] Add test case for MessageId by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6036
• [ISSUE #6046]📝Update README to include new crates and descriptions for rocketmq components by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6047
• [ISSUE #5750][Enhancement✨] Add #[inline] for MessageExt some methods by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6037
• [ISSUE #6048]📝Update README to reflect project name change and enhance documentation for RocketMQ-Rust dashboard implementations by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6049
• [ISSUE #6052]Remove useless file by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6053
• [ISSUE #6050]🔨Update CI configuration to ignore changes in README.md by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6051
• [ISSUE #6057]🔨Update CI configuration to ignore all README files in rocketmq-dashboard by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6058
• [ISSUE #6054]✨Update dependencies in Cargo.lock to latest versions by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6055
• [ISSUE #5722][Enhancement✨] Remove useless code from perm_broker_header.rs by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6039
• [ISSUE #6056]📝Add Chinese README for RocketMQ-Rust management console by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6059
• [ISSUE #5720][Test🧪] Add test case for LockBatchResponseBody by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6040
• feat: implement GetUserSubCommand (#5662) by @magogosora in https://github.com/mxsm/rocketmq-rust/pull/6041
• [ISSUE #6060]Refactor rocketmq-example package configuration and update dependencies by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6061
• [ISSUE #6062]🔨Rename CI configuration file and update paths to ignore 'rocketmq-example' by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6063
• [ISSUE #6066]🔨Update CI configuration to ignore all files in 'rocketmq-example' directory by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6067
• [ISSUE #6064]📝Update README and add Chinese translation for RocketMQ-Rust examples by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6065
• [ISSUE #6068]🔨Add CI configuration for RocketMQ example with multi-platform support by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6069
• [ISSUE #5700][Enhancement✨] Remove about Java useless comments by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6075
• [ISSUE #6078]🚀Add rocketmq-admin-cli package with initial implementation and CLI features by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6079
• [ISSUE #5802][Doc📝] Update README.md for improved formatting and readability by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6076
• refactor(remoting): avoid cloning topic stats offset table by @willwang-io in https://github.com/mxsm/rocketmq-rust/pull/6084
• [ISSUE #6085]🚀Implement authentication module with login functionality and error handling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6086
• [ISSUE #6077][Test🧪] Add test case for CheckClientRequestBody by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6080
• [ISSUE #6097]🔧Update CI configuration for RocketMQ-Rust dashboard with test execution by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6098
• Bump criterion from 0.8.1 to 0.8.2 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6104
• [ISSUE #6074][Test🧪] Add test case for TopicQueueMappingSerializeWrapper by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6081
• [ISSUE #5663]🚀Implement ListAcl command for ACL enumeration by @willwang-io in https://github.com/mxsm/rocketmq-rust/pull/6101
• [ISSUE #6070][Test🧪] Add test case for ConsumeStats by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6083
• [ISSUE #6105]📝Remove useless file from website by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6106
• [ISSUE #6107]📝Add Chinese localization support and update README for new start script by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6108
• [ISSUE #6109]🔧Update GitHub Actions deployment configuration for main branch and pull requests by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6110
• [ISSUE #6111]📝Update README files for improved contact information and add Chinese localization by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6112
• [ISSUE #6096][Test🧪] Add test case for RegisterBrokerResult by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6103
• [ISSUE #6100][ISSUE #6099][Enhancement✨]Remove useless code from many_pull_request.rs &Update copyright notice and license information in strategy.rs by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6102
• [ISSUE #6087]🧪Add test case for LogicQueueMappingItem by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6113
• [ISSUE #6116]🚀Add re-exported protocol bodies and headers for simplified access by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6117
• [ISSUE #6118]🚀Add prelude module for simplified imports and reorganize re-exports in protocol headers and bodies by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6119
• [ISSUE #6120]🚀Enhance top-level exports with additional protocol headers and bodies for transaction, offset management, and client operations by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6121
• [ISSUE #6072][Test🧪] Add test case for TopicStatsTable by @oopscompiled in https://github.com/mxsm/rocketmq-rust/pull/6082
• [ISSUE #6089]🧪Add test case for TopicQueueMappingInfo by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6114
• [ISSUE #6122]✨Add static topic bodies and corresponding test for re-exports by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6123
• Bump anyhow from 1.0.100 to 1.0.101 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6138
• Bump time from 0.3.46 to 0.3.47 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6139
• [ISSUE #6090]🧪Add test case for TopicQueueMappingContext by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6141
• [ISSUE #6088]🧪Add test case for TopicConfigAndQueueMapping by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6140
• [ISSUE #6136]Add test case for GetMaxOffsetRequestHeader by @Andra-Fauzi in https://github.com/mxsm/rocketmq-rust/pull/6137
• Bump sysinfo from 0.38.0 to 0.38.1 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6148
• Bump reqwest from 0.13.1 to 0.13.2 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6147
• [ISSUE #6071] Refactor ConsumeStatsList serde field names to camelCase by @Xylphy in https://github.com/mxsm/rocketmq-rust/pull/6146
• [ISSUE #6091]🧪Add test case for TopicQueueMappingDetail by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6142
• Bump bytes from 1.11.0 to 1.11.1 in /rocketmq-dashboard/rocketmq-dashboard-tauri/src-tauri by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6144
• [ISSUE #6092 ]🧪Add test case for TopicQueueMappingOne by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6143
• Bump vite from 6.3.5 to 6.4.1 in /rocketmq-dashboard/rocketmq-dashboard-tauri by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6150
• [ISSUE #5652] Add batch subscription group update command by @willwang-io in https://github.com/mxsm/rocketmq-rust/pull/6145
• Bump time from 0.3.46 to 0.3.47 in /rocketmq-dashboard/rocketmq-dashboard-gpui by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6182
• [ISSUE #6124]🧪Add test case for PermBrokerHeader by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6181
• [ISSUE #6094]🧪Add test case for GroupRetryPolicy and SimpleSubscriptionData by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6180
• [ISSUE #6194]Bump dependencies: anyhow to 1.0.101, time to 0.3.47, and time-macros to 0.2.27 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6195
• Bump time from 0.3.46 to 0.3.47 in /rocketmq-example by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6196
• Bump regex from 1.12.2 to 1.12.3 by @dependabot[bot] in https://github.com/mxsm/rocketmq-rust/pull/6042
• [ISSUE #6198]✨Re-export RPC types for convenient access by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6199
• [ISSUE #6222]✨Remove Jekyll GitHub Pages workflow configuration by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6223
• [ISSUE #6220]🚀Add contribution guide and architecture documentation for RocketMQ Rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6221
• Add unit tests for timer metrics wrapper by @willwang-io in https://github.com/mxsm/rocketmq-rust/pull/6224
• [Enhancement✨] Remove useless test case consumer_group_info_update_channel from consumer_group_info.rs by @onenewcode in https://github.com/mxsm/rocketmq-rust/pull/6225
• [ISSUE #6126]🧪Add test case for UnRegisterBrokerRequestHeader by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6226
• [ISSUE #6130]🧪Add test case for NotifyBrokerRoleChangedRequestHeader by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6227
• [ISSUE #6231]🚀Implement Prodcer recall_message by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6232
• [ISSUE #6134]🧪Add test case for GetTopicConfigRequestHeader by @WaterWhisperer in https://github.com/mxsm/rocketmq-rust/pull/6228
• [ISSUE #6229]🚀Implement Prodcer recall_message by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6230
• Update license headers across Rust sources by @willwang-io in https://github.com/mxsm/rocketmq-rust/pull/6233
• Add unit tests for HeartbeatRequestHeader by @willwang-io in https://github.com/mxsm/rocketmq-rust/pull/6234
• [ISSUE #6236]Add some request code by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/6237
• Add unit tests for NotificationResponseHeader by @willwang-io in https://github.com/mxsm/rocketmq-rust/pull/6235