Announcement: RocketMQ Rust 🔖v1.0.0 has been released

New Feature and improve performance

• ✨ Core services include NameServer, Controller, Broker, and Proxy, together with the Rust client and administration tools.
• ✨ Runtime ownership, typed errors, transport, storage, security, and observability now have dedicated core crates and explicit lifecycle boundaries.
• ✨ Dashboard Web, MCP, and SRE are available as separately packaged service components. Their standalone APIs are outside the core 1.0 compatibility surface.
• 🚀 A dedicated GitHub Actions workflow publishes the 27 core crates and 13 individual Docker Hub images for linux/amd64, with SBOMs, vulnerability scans, signatures, and resumable publication.
• 🔒 Dashboard Web backend and the five SRE backends use the patched Debian 13 runtime that resolved the CRITICAL Perl/zlib image findings.
• ⚙️ The SRE UI accepts its public OIDC issuer and client ID at container startup, so the same image can serve multiple deployments.
• 🐛 Fix bugs and strengthen regression coverage across the client, Broker, Controller, storage, protocol, and service lifecycle.

Upgrade notes

The transition from 0.9 to 1.0 includes deliberate Rust source API changes. Review the 1.0 API migration guide and runtime migration notes before upgrading an application. The request-header derive is now RequestHeaderCodec; client runtime startup is fallible; runtime ownership and scheduling APIs use the explicit owner model. Store and observability APIs also include source changes documented in the repository changelog.

For Broker data, follow the upgrade and rollback guide, retain backups, and run the downgrade preflight before returning to an older Rust Broker. Controller HA is Rust-native; the guide defines the supported interoperability and persisted-format boundaries.

Packages and containers

The release source is tagged v1.0.0. Crates.io and Docker Hub publication run through Release crates and Docker Hub images; the existing signed service image workflow publishes to GHCR. Registry publication completes asynchronously; check the corresponding workflow result before using a package or image.

Docker Hub repositories use the mxsm/rocketmq-rust-<component>:1.0.0 naming scheme. See the release and container configuration guide for all 13 repositories, image tags, and deployment settings. SRE UI deployments must supply VITE_SRE_OIDC_AUTHORITY and VITE_SRE_OIDC_CLIENT_ID when starting the container.

What's Changed

GitHub generated 1774 pull request entries since v0.9.0. The complete generated changelog is attached to this release. Selected changes are listed below.

• [ISSUE #7470]🚀add observability support: implement core attributes, configuration, and metrics structures by @mxsm in #7471
• [ISSUE #7476]🚀add observability metrics: implement metrics recording, configuration, and examples for broker observability by @mxsm in #7477
• [ISSUE #7485]✨Enhance observability: add metrics for RocksDB, proxy, and message processing by @mxsm in #7486
• [ISSUE #7876]♻️Establish error architecture foundation by @mxsm in #7877
• [ISSUE #7887]✨Add recovery and observability policies by @mxsm in #7888
• [ISSUE #8129]✨Add rocketmq-mcp configuration startup layer by @mxsm in #8130
• [ISSUE #8139]🚀Add rocketmq-mcp runbook prompts by @mxsm in #8140
• [ISSUE #8159]✨Define rocketmq-mcp architecture and measurable baselines by @mxsm in #8160
• [ISSUE #8170]🚀Add principal-aware authorization and async audit by @mxsm in #8171
• [ISSUE #8180]♻️Establish architecture safety and foundation contracts by @mxsm in #8181
• [ISSUE #8212]♻️Extract RocksDB foundation into its owner crate by @mxsm in #8213
• [ISSUE #8282]♻️Establish reproducible container foundation and supply-chain gates by @mxsm in #8283
• [ISSUE #8303]♻️Replace unsafe NameServer runtime ownership by @mxsm in #8304
• [ISSUE #8768]♻️Unify production readiness observability contracts by @mxsm in #8769
• [ISSUE #8922]✨Integrate enterprise identity secrets storage and observability by @mxsm in #8923
• [ISSUE #11033]✨Add verified crate and Docker Hub releases by @mxsm in #11034
• [ISSUE #10974]✨Publish the admin tools and dashboard-common to crates.io with the other workspace members by @mxsm in #10975
• [ISSUE #10937]📝Put type doc comments before derives in config.rs by @WaterWhisperer in #10978
• [ISSUE #10976]🐛Client runtime ownership test races task registry cleanup by @WaterWhisperer in #10977
• [ISSUE #10940]📝Put type doc comments before derives in resource_budget/clock.rs by @WaterWhisperer in #10979
• [ISSUE #10939]📝Put type doc comments before derives in blocking/diagnostics.rs by @WaterWhisperer in #10980
• [ISSUE #10944]📝Put type doc comments before derives in resource_budget/queue.rs by @WaterWhisperer in #10981
• [ISSUE #10938]📝Put type doc comments before derives in blocking/policy.rs by @WaterWhisperer in #10982
• [ISSUE #10941]📝Put type doc comments before derives in resource_budget/limit.rs by @WaterWhisperer in #10983
• [ISSUE #10984]✨Harden runtime admission, resource ownership and bounded diagnostics by @mxsm in #10985
• Bump thiserror from 2.0.20 to 2.0.21 in /rocketmq-ai/rocketmq-mcp by @dependabot[bot] in #10988
• Bump @types/node from 26.6.2 to 26.6.3 in /rocketmq-ai/rocketmq-sre/ui by @dependabot[bot] in #10990
• Bump jsonschema from 0.57.0 to 0.58.0 in /rocketmq-ai/rocketmq-sre by @dependabot[bot] in #10992
• Bump vitest from 5.0.1 to 5.0.2 in /rocketmq-ai/rocketmq-sre/ui by @dependabot[bot] in #10996
• Bump thiserror from 2.0.20 to 2.0.21 in /rocketmq-ai/rocketmq-sre by @dependabot[bot] in #10989
• Bump rmcp from 3.4.0 to 3.4.1 in /rocketmq-ai/rocketmq-mcp by @dependabot[bot] in #10998
• Bump lucide-react from 1.47.0 to 1.48.0 in /rocketmq-ai/rocketmq-sre/ui by @dependabot[bot] in #10997
• Bump jsonschema from 0.57.0 to 0.58.0 in /rocketmq-ai/rocketmq-mcp by @dependabot[bot] in #10991
• Bump rmcp from 3.4.0 to 3.4.1 in /rocketmq-ai/rocketmq-sre by @dependabot[bot] in #10999
• Bump smallvec from 1.16.1 to 1.16.2 in /rocketmq-ai/rocketmq-mcp by @dependabot[bot] in #10995
• Bump vite from 8.3.0 to 8.3.1 in /rocketmq-ai/rocketmq-sre/ui by @dependabot[bot] in #10994
• [ISSUE #10952]🚀Configure NameServer runtime threads from TOML by @labyrinthgarden in #10967
• [ISSUE #11000]♻️Retire the obsolete RemotingSerializable derive before 1.0 by @WaterWhisperer in #11001
• [ISSUE #11002]♻️Remove no-op producer backpressure lock methods before 1.0 by @WaterWhisperer in #11003
• [ISSUE #11004]🐛Register new runtime exports in the public API intent manifest by @WaterWhisperer in #11005
• [ISSUE #11006]🐛Align OpenTelemetry dependencies and upgrade pending crates by @mxsm in #11007
• [ISSUE #11008]✨Remove the dedicated security audit workflow by @mxsm in #11009
• [ISSUE #11010]✨Consolidate Kubernetes CI and retire automated fault and SLO workflows by @mxsm in #11011
• [ISSUE #11012]🐛Avoid fixed-port collisions in Raft controller tests by @mxsm in #11013
• Bump jsonschema from 0.58.0 to 0.58.1 in /rocketmq-ai/rocketmq-sre by @dependabot[bot] in #11017
• Bump jsonschema from 0.58.0 to 0.58.1 in /rocketmq-ai/rocketmq-mcp by @dependabot[bot] in #11018
• Bump smallvec from 1.16.1 to 1.16.2 by @dependabot[bot] in #11015
• [ISSUE #11019]🐛Fix Dashboard topic shutdown timeout assertions by @mxsm in https://github....

Announcement: RocketMQ Rust 🔖v0.9.0 has been released

New Feature and improve performance

• ✨ Fix some bugs
• ⚡️ Optimize code performance

What's Changed

• [ISSUE #6979]🌐Update announcement messages to reflect RocketMQ-Rust v0.8.0 release by @mxsm in #6980
• [ISSUE #6981]✨Add unit tests for NameServerBootstrap and enhance route info manager methods by @mxsm in #6982
• [ISSUE #6983]✨Enhance NameServerBootstrap initialization with runtime config validation and improve topic route data encoding for standard JSON compliance by @mxsm in #6984
• [ISSUE #6985]✨Enhance broker management by adding channel lifecycle handling and improving unregister logic in route info manager by @mxsm in #6986
• [ISSUE #6987]✨Enhance runtime configuration management by adding methods for retrieving and updating server and client configurations by @mxsm in #6988
• [ISSUE #6989]♻️Refactor configuration handling by replacing HashMap with Vec for improved performance and add new broker address retrieval methods in broker and cluster tables by @mxsm in #6990
• [ISSUE #6991]♻️Refactor topic management in RouteInfoManager to optimize broker topic retrieval and cleanup logic by @mxsm in #6992
• [ISSUE #6914]📝Complete architecture section parity with English by @WaterWhisperer in #6993
• [ISSUE #6994]♻️Refactor topic management in TopicQueueTable to improve broker topic indexing and enhance cleanup logic by @mxsm in #6995
• [ISSUE #6996]✨Enhance route management by adding shutdown handling and improving KV config processing in integration tests by @mxsm in #6997
• Bump sha1 to 0.11.0 and align hmac compatibility by @dependabot[bot] in #6971
• [ISSUE #6998]✨Add benchmark for topic table hot path and implement related integration tests by @mxsm in #6999
• [ISSUE #7000]🚀Implement cluster test support in NameServer, adding controller configuration and route lookup functionality by @mxsm in #7001
• [ISSUE #7002]🚀Add Lite message handling with request and response headers, and implement related functionality by @mxsm in #7004
• [ISSUE #7003]✨Refactor timer message store handling and add LMQ topic management methods by @mxsm in #7005
• [ISSUE #7006]Implement Lite subscription control processor and registry, adding support for partial and complete subscriptions by @mxsm in #7007
• [ISSUE #7008]🚀Implement LiteManagerProcessor for handling Lite subscription requests and responses by @mxsm in #7009
• [ISSUE #7010]🚀Add LiteGroupInfo handling and triggerLiteDispatch processor to LiteManager by @mxsm in #7011
• [ISSUE #7012]🚀Implement LiteEventDispatcher and LiteLifecycleManager for enhanced Lite message handling by @mxsm in #7013
• [ISSUE #7014]🚀Implement PopLiteMessageProcessor for handling Lite message pop requests and enhance Lite event dispatching by @mxsm in #7015
• [ISSUE #7016]🚀Add Lite topic support and configuration options for enhanced Lite message handling by @mxsm in #7017
• [ISSUE #7018]🚀Implement PopLiteLongPollingService and integrate with Lite message processing by @mxsm in #7019
• [ISSUE #7020]🚀Enhance PopLiteMessageProcessor with order info management and improve FIFO handling for pop requests by @mxsm in #7021
• [ISSUE #7022]🚀Enhance Lite message processing with order info management and validation for parent topics by @mxsm in #7023
• [ISSUE #7024]🚀Implement Lite consumer lag calculation and sharding logic for enhanced message processing by @mxsm in #7025
• [ISSUE #7026]✨Enhance Lite subscription management with quota checks, offset reset options, and improved subscription handling by @mxsm in #7027
• [ISSUE #7028]🚀Add versioning to LiteSubscription and related components for improved subscription management by @mxsm in #7029
• [ISSUE #6914]📝Complete producer section parity with English and fix links by @WaterWhisperer in #7030
• Bump hmac from 0.13.0-rc.6 to 0.13.0 by @dependabot[bot] in #7031
• Bump local-ip-address from 0.6.10 to 0.6.11 by @dependabot[bot] in #7032
• [ISSUE #6914]📝Complete consumer section parity with English and fix deps by @WaterWhisperer in #7033
• Bump libc from 0.2.183 to 0.2.184 by @dependabot[bot] in #7034
• Bump tokio from 1.50.0 to 1.51.0 by @dependabot[bot] in #7037
• [ISSUE #6914]📝Complete configuration section parity with English by @WaterWhisperer in #7036
• [ISSUE #7038] feat: clean AdminBrokerProcessor stub paths and admin parity gaps by @mxsm in #7039
• [ISSUE #7040]🚀Add ACL management features with create, update, and get request handlers by @mxsm in #7041
• [ISSUE #7042]🚀feat(client): implement client configuration check and enhance heartbeat handling by @mxsm in #7043
• [ISSUE #7044]🚀feat(broker): enhance cold data flow control with configuration management and info retrieval by @mxsm in #7045
• [ISSUE #7046]🚀feat(consumer): implement query correction offset and consume message directly handlers by @mxsm in #7047
• [ISSUE #7048]🚀feat(filter): implement SQL92 expression compilation and evaluation, enhance consumer filter management by @mxsm in #7049
• [ISSUE #7050]🚀feat(filter): enhance SQL92 expression support with new operators and improve evaluation context by @mxsm in #7051
• [ISSUE #7052]🚀feat(tests): add comprehensive tests for subscription data handling and filter management by @mxsm in #7053
• [ISSUE #7054]🚀feat(filter): optimize Bloom filter data handling with caching and performance improvements by @mxsm in #7055
• [ISSUE #7056]🚀feat(tests): add tests for consumer filter manager and pop message processor with SQL expression handling by @mxsm in #7057
• [ISSUE #7058]🚀feat(dispatch): implement bounded dispatch with deferred overflow handling and add export rocksdb config request header by @mxsm in #7059
• [ISSUE #7060]🚀feat(commit-log): enhance commit log accessors and add new methods for offset management and data retrieval by @mxsm in #7061
• [ISSUE #7062]🚀feat(flush-consume-queue): implement flush consume queue service with checkpoint persistence and improve configuration handling by @mxsm in #7063
• [ISSUE #7064]🚀feat(commit-log): implement shutdown and destroy methods with proper resource management and add tests for commit log functionality by @mxsm in #7065
• [ISSUE #6914]📝Complete faq section parity with English by @WaterWhisperer in #7068
• [ISSUE #7066]🚀feat(commit-log): implement property CRC parsing and verification, enhance bulk data retrieval, and add tests for message integrity by @mxsm in #7067
• [ISSUE #7069]🚀feat(commit-log): implement file deletion services for expired commit logs and consume queues, enhance offset correction logic, and add tests for cleanup functionality by @mxsm in #7070
• [ISSUE #7071]✨enhance(ha): enhance transfer header handling with controller mode support, update related logic, and add tests for confirm offset functionality by @mxsm in #7072
• [ISSUE #7073]✨enhance(message-store): enhance master store handling with thread-safe access and add send message back hook support by @mxsm in #7074
• [ISSUE #7075]🚀refactor(allocate-mapped-file-service): refactor allocation to use blocking thread for file allocation and clean up expired consumer queues synchronously by @mxsm in #7076
• [ISSUE #7077]✨enhance(ha): add support for snapshotting acked replicas and streamline wakeup logic by @mxsm in #7078
• [ISSUE #7079]✨enhance(benchmarks): add new performance benchmarks for async flush and batch processing by @mxsm in #7080
• [ISSUE #7081]✨enhance(ha): add integration tests for HA semantics and recovery behavior by @mxsm in #7082
• [ISSUE #6914]📝docs(website): align API examples with current Rust client by @WaterWhisperer in https://gi...

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 https://github.com/mxsm/rocketmq-rust/p...

Announcement: RocketMQ Rust 🔖v0.7.0 has been released

New Feature and improve performance

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

What's Changed

• [ISSUE #3778]📝Update release notes and documentation for version 0.6.0, reflecting new features and changes by @mxsm in #3779
• [ISSUE #3780]📝Update to Version 0.7.0 for Next-Stage Development by @mxsm in #3781
• Bump serde_json from 1.0.142 to 1.0.143 by @dependabot[bot] in #3782
• Bump cfg-if from 1.0.1 to 1.0.3 by @dependabot[bot] in #3783
• [ISSUE #3784]🚀Simple in-process scheduling framework (ScheduledTaskManager) by @mxsm in #3785
• Bump thiserror from 2.0.15 to 2.0.16 by @dependabot[bot] in #3787
• Bump tempfile from 3.20.0 to 3.21.0 by @dependabot[bot] in #3788
• feat: Introduce #[inline] for Builder methods by @4ddx in #3786
• [ISSUE #3789]📝Enhance documentation for WeakArcMut and ArcMut structs with safety notes by @mxsm in #3790
• [ISSUE #3791]⚡️Evolve ScheduledTaskManager: cron layer, jitter, metrics, shutdown integration by @mxsm in #3792
• [ISSUE #3794]✨Add fixed-rate and fixed-delay task scheduling methods to ScheduledTaskManager by @mxsm in #3795
• Bump form_urlencoded from 1.2.1 to 1.2.2 by @dependabot[bot] in #3798
• [ISSUE #3796]✨Implement asynchronous fixed-rate, fixed-delay, and fixed-rate-no-overlap task scheduling methods in ScheduledTaskManager by @mxsm in #3797
• [ISSUE #3799]♻️Migrate BrokerRuntime scheduled loops to ScheduledTaskManager by @mxsm in #3800
• [ISSUE #3802]♻️Refactor QueueTypeUtils to accept Option references directly for improved clarity and performance by @mxsm in #3803
• [ISSUE #3804]Add slave synchronization scaffolding and update MessageStore HA API by @mxsm in #3805
• Bump memmap2 from 0.9.7 to 0.9.8 by @dependabot[bot] in #3806
• Bump url from 2.5.4 to 2.5.6 by @dependabot[bot] in #3807
• [ISSUE #3808]📝Add configuration files for broker roles and settings by @mxsm in #3809
• [ISSUE #3813]✨Add simple broker config templates (master and slave) under distribution/config/broker by @mxsm in #3814
• [ISSUE #3815]♻️ Split MessageStore init from start and align BrokerRuntime initialization flow by @mxsm in #3816
• [ISSUE #3818]♻️ Refactor MessageStore commit log getters to return refs and add mutable variants by @mxsm in #3819
• refactor: return Option<&String>> on consumer_group by @4ddx in #3824
• [ISSUE #3827]♻️Consolidate server config: use BrokerConfig.broker_server_config across BrokerRuntime/Bootstrap by @mxsm in #3830
• [ISSUE #3829]⚡️Add brokerServerConfig section to broker-simple-slave.toml and move listenPort under it by @mxsm in #3831
• Add startup logo by @watchgou in #3828
• [ISSUE #3834]⚡️Standardize and centralize startup ASCII logo usage by @mxsm in #3835
• [ISSUE #3837]🐛HA client didn’t refresh last_read_timestamp on reads, causing premature housekeeping disconnects by @mxsm in #3838
• Refactor GeneralHAService to use enum for HA service by @dhvll in #3765
• [ISSUE #3839]♻️Refactor DefaultHAService initialization to accept GeneralHAService as a parameter by @mxsm in #3840
• documentation: add RocketMQ-RustBroker ASCII logo to broker-bootstrap-server by @4ddx in #3841
• [ISSUE #3843]Add test coverage for multi_dispatch_utils in queue.rs (LMQ key, dispatch checks) by @mxsm in #3844
• #3826: Refactor Make is_compaction take Option<&TopicConfig> instead … by @kashifsoofi in #3845
• [ISSUE #3846]⚡️Integrate StoreStatsService hooks and CQ checkpoint updates; prepare multi-dispatch LMQ path by @mxsm in #3847
• refactor: make ConsumeMessageDirectlyResult::remark return Option<&CheetahString> by @4ddx in #3842
• Improve GroupRetryPolicy accessors to return Option<&T> instead of &Option by @schechenkin in #3850
• [ISSUE #3851]♻️Change put_request to accept GroupCommitRequest instead of ArcMut by @mxsm in #3852
• Bump regex from 1.11.1 to 1.11.2 by @dependabot[bot] in #3854
• [ISSUE #3855]🐛HA GroupTransferService ack threshold and lock handling cause unnecessary timeouts by @mxsm in #3856
• [ISSUE #3857]📝Expand rocketmq-error README with multi-crate error architecture overview by @mxsm in #3858
• Bump url from 2.5.6 to 2.5.7 by @dependabot[bot] in #3860
• enhancement: remove sync_unsafe_cell feature from rocketmq-namesrv by @4ddx in #3862
• #3823: Adjust ConsumeMessageDirectlyResult::consume_result by @kashifsoofi in #3848
• Update commit_log.rs by @JithinKamineni in #3861
• [ISSUE #3864]🚀Add error handling modules for various components by @mxsm in #3865
• [ISSUE #3866]⚡️Update message handling in content_show.rs for improved clarity and type safety by @mxsm in #3867
• Bump clap from 4.5.45 to 4.5.46 by @dependabot[bot] in #3868
• [ISSUE #3869]♻️Make SlaveSynchronize generic and optional; integrate safely into BrokerRuntime by @mxsm in #3870
• [ISSUE #3871]🚀Implement sync_all method in SlaveSynchronize for comprehensive synchronization by @mxsm in #3872
• Bump tracing-subscriber from 0.3.19 to 0.3.20 by @dependabot[bot] in #3877
• Bump config from 0.15.14 to 0.15.15 by @dependabot[bot] in #3878
• [ISSUE #3880]♻️Simplify DataVersion counter from Arc to AtomicI64 in remoting protocol by @mxsm in #3881
• [ISSUE #3882]⚡️Implement master→slave metadata sync (topic configs, static queue mappings) and add BrokerOuterAPI.get_all_topic_config by @mxsm in #3883
• [ISSUE #3885]♻️Make RemotingCommand::body() ergonomic (Option<&Bytes>) and update call sites by @mxsm in #3886
• [ISSUE #3887]✨Add ConsumerOffsetSerializeWrapper protocol and export module by @mxsm in #3888
• [ISSUE #3889]✨Normalize ConsumerOffsetSerializeWrapper JSON field casing and add accessors by @mxsm in #3890
• [ISSUE #3891]✨Implement master→slave consumer offset sync and add BrokerOuterAPI.get_all_consumer_offset by @mxsm in #3892
• [ISSUE #3893]✨Implement master→slave delay offset sync and add BrokerOuterAPI.get_delay_offset⚡️ by @mxsm in #3894
• [ISSUE #3895]✨Add SubscriptionGroupWrapper protocol and export module⚡️ by @mxsm in #3896
• [ISSUE #3897]✨Implement master→slave subscription group sync and add BrokerOuterAPI.get_all_subscription_group_config⚡️ by @mxsm in #3899
• [ISSUE #3900]🚀Add MessageRequestModeSerializeWrapper protocol and export module by @mxsm in #3901
• [ISSUE #3902]🚀Add get_message_request_mode method and update MessageRequestModeManager in broker APIs by @mxsm in #3903
• [ISSUE #3904]🚀Introduce TimerMetricsSerializeWrapper in remoting protocol and expose module by @mxsm in #3905
• [ISSUE #3906]🚀Add broker handler for GetAllDelayOffset to expose delay offset data by @mxsm in #3907
• [ISSUE #3909]🚀Feature flag mismatch: common enables rocketmq-error with serde_json, but error crate exposes with_serde by @mxsm in #3910
• [ISSUE #3908]♻️Unify JSON error handling: replace JsonError with feature-gated SerdeJsonError and simplify conversions by @mxsm in #3911
• [ISSUE #3913]⚡️Expose GetAllSubscriptionGroupConfig via admin broker processor by @mxsm in #3914
• [ISSUE #3915]⚡️Make GroupRetryPolicy default-policy allocation lazy and non-owning by @mxsm in #3916
• [ISSUE #3920]♻️ Avoid cloning ...

🔊Announcement: RocketMQ Rust 🔖v0.6.0 has been released

New Feature and improve performance

• ✨ Fix some bugs
• ⚡️ Optimize code performance
• 🚀 Support Slave Master and so on

What's Changed

• [ISSUE #3282]⚡️Add Release Notes for Version 0.5.0 by @mxsm in #3283
• [ISSUE #3284]📝Update to Version 0.6.0 for Next-Stage Development by @mxsm in #3285
• [ISSUE #3286]📝Update rocketmq-broker Cargo.toml by @mxsm in #3287
• [ISSUE #3288]📝Update package_publish_workspace script by @mxsm in #3289
• Bump criterion from 0.5.1 to 0.6.0 by @dependabot[bot] in #3291
• [ISSUE #3290]🐛Fix parse_config_file file error by @mxsm in #3294
• [ISSUE #3296]⚡️Optimize rocketmq-example crate Cargo.toml by @mxsm in #3297
• [ISSUE #3298]Remove dead code from the LocalFileMessageStore by @SleepyStew in #3299
• [ISSUE #3300]⚡️Optimize CommitLog put_message and put_messages methods signature by @mxsm in #3301
• [ISSUE #3302]⚡️Remove LocalFileMessageStore useless code by @mxsm in #3303
• [ISSUE #3305]🚀CommitLog put messages add unlockMappedFile logic by @mxsm in #3306
• [ISSUE #3308]🚀Build the command framework based on clap by @mxsm in #3309
• [ISSUE #3310]🚀Add the second-level command show by @mxsm in #3311
• [ISSUE #3319]🚀Add getNamesrvConfig command clap💫 by @mxsm in #3320
• [ISSUE #3321]🚀Add CommandExecute trait💫 by @mxsm in #3322
• [ISSUE #3323]🚀Change common arg namesrvAddr required to false💫 by @mxsm in #3324
• [ISSUE #3325]⚡️Change CommandExecute#execute as async by @mxsm in #3326
• Bump uuid from 1.16.0 to 1.17.0 by @dependabot[bot] in #3327
• [ISSUE #3328]🐛Fix MQClientInstance start fetch_name_server_addr error💫 by @mxsm in #3329
• [ISSUE #3330]⚡️Unify the JSON data format returned by GET_NAMESRV_CONFIG in Rust and Java versions💫 by @mxsm in #3331
• [ISSUE #3295]add updateAndSubscripGroup func by @578223592 in #3293
• [ISSUE #3315]🚀Implement GetNamesrvConfigCommand for name server tool💫 by @mxsm in #3333
• Bump tokio from 1.45.0 to 1.45.1 by @dependabot[bot] in #3334
• [ISSUE #3337]📝Add TransactionalMessageBridge#parse_half_message_inner💫 by @mxsm in #3338
• Bump clap from 4.5.38 to 4.5.39 by @dependabot[bot] in #3340
• Bump reqwest from 0.12.15 to 0.12.16 by @dependabot[bot] in #3341
• [ISSUE #3335 ]Remove useless code from TransactionalMessageBridge by @samuraikillers in #3339
• [ISSUE #3342]🚀Add some methods for TransactionalMessageBridge💫 by @mxsm in #3343
• Bump reqwest from 0.12.16 to 0.12.18 by @dependabot[bot] in #3344
• [ISSUE #3346]♻️Refactor end_transaction_processor to improve response handling in commit_message by @mxsm in #3347
• [ISSUE #3314]Implement DeleteKvConfigCommand for name server tool by @578223592 in #3332
• [ISSUE #3348]📝Update copyright notice in LICENSE-MIT to reflect current contributors by @mxsm in #3349
• Bump num_cpus from 1.16.0 to 1.17.0 by @dependabot[bot] in #3350
• [ISSUE #3316]🚀Implement UpdateKvConfigCommand for name server tool by @578223592 in #3351
• [ISSUE #3352]🚀Add Transaction Producer documentation and update navigation structure💫 by @mxsm in #3353
• [ISSUE #3354]📝Enhance Transaction Producer documentation with detailed message flow and code example💫 by @mxsm in #3355
• [ISSUE #3358]🚀transactional message service with internal check implementation and message handling improvements💫 by @mxsm in #3359
• [ISSUE #3317]🚀Implement UpdateNamesrvConfigCommand for name server tool by @578223592 in #3356
• [ISSUE #3313]🚀Implement AddWritePermSubCommand for name server tool by @578223592 in #3360
• [ISSUE ##3318]🚀Implement WipeWritePermSubCommand for name server tool by @578223592 in #3361
• [ISSUE #3362]🚀Add ServiceError enumeration and service task macro implementation💫 by @mxsm in #3363
• Bump reqwest from 0.12.18 to 0.12.19 by @dependabot[bot] in #3365
• [ISSUE #3366]🚀Add ServiceTaskContext struct and update service task methods to use context by @mxsm in #3367
• [ISSUE #3364]🚀Refactor TransactionalMessageCheckService to use ServiceTaskContext and improve async handling💫 by @mxsm in #3368
• Bump sysinfo from 0.35.1 to 0.35.2 by @dependabot[bot] in #3369
• [ISSUE #3370]⚡️Update minimum supported Rust version to 1.85.0 by @mxsm in #3371
• [ISSUE #3372]📝Update README.md by @mxsm in #3373
• [ISSUE #3374]🚀Implement a scheduled task dispatcher by @mxsm in #3375
• Bump cron from 0.12.1 to 0.15.0 by @dependabot[bot] in #3376
• Bump tabled from 0.19.0 to 0.20.0 by @dependabot[bot] in #3377
• [ISSUE #3380]⚡️Optimize cargo clippy -- -D warnings by @mxsm in #3381
• [ISSUE #3378]🚀Add advanced task scheduling features with delay support by @mxsm in #3379
• [ISSUE #3382]♻️Refactor ServiceTask trait to enhance service logic implementation and provide default behavior for on_wait_end by @mxsm in #3383
• [ISSUE #3384]♻️Refactor service task structures and rename for clarity by @mxsm in #3385
• [ISSUE #3414]⚡️Enhance EndTransactionRequestHeader struct with additional fields for transaction state and offsets by @mxsm in #3415
• [ISSUE #3416]🚀Add methods for managing message body in message structures by @mxsm in #3417
• [ISSUE #3418]♻️Refactor end_message_transaction function to accept mutable reference and improve message handling by @mxsm in #3419
• [ISSUE #3420]♻️Refactor make_op_message_inner function to accept ownership of Message and simplify message handling by @mxsm in #3421
• [ISSUE #3422]🚀Add wakeup method to ServiceTask for improved notification handling by @mxsm in #3423
• [ISSUE #3424]🚀Add transaction_op_batch_interval to BrokerConfig and refactor related services for improved transaction handling by @mxsm in #3425
• [ISSUE #3426]♻️Refactor transactional message service to use WeakArcMut for improved memory management by @mxsm in #3427
• [ISSUE #3428]♻️Refactor DefaultTransactionalMessageCheckListener to simplify structure and enhance message handling by @mxsm in #3429
• [ISSUE #3430]♻️Refactor resolve_half_msg method for improved error handling and clarity by @mxsm in #3431
• Bump clap from 4.5.39 to 4.5.40 by @dependabot[bot] in #3432
• Bump bytemuck from 1.23.0 to 1.23.1 by @dependabot[bot] in #3433
• Bump flate2 from 1.1.1 to 1.1.2 by @dependabot[bot] in #3435
• Bump cfg-if from 1.0.0 to 1.0.1 by @dependabot[bot] in #3434
• [ISSUE #3436]⚡️Improve message handling to simplify topic length retrieval and improve clarity by @mxsm in #3437
• [ISSUE #3438]⚡️Enhancement message handling in transactional_message_bridge for improved clarity and error handling by @mxsm in #3439
• [ISSUE #3440]🐛Fix Broker can not send_check_message to client by @mxsm in #3441
• [ISSUE #3442]📝Clarify message property configuration in end_transaction_processor by @mxsm in #3443
• [ISSUE #3444]📝Enhance documentation for fill_op_remove_map function with detailed argument and return descriptions by @mxsm in #3445
• Bump reqwest from 0.12.19 to 0.12.20 by @dependabot[bot] in #3447
• Bump syn from 2.0.101 to 2.0.102 by @depend...

🔊Announcement: RocketMQ Rust 🔖v0.5.0 has been released

New Feature and improve performance

• ✨Fix some bugs
• ⚡️ Optimize code performance
• 🚀 Support Pop Message and so on

What's Changed

• [ISSUE #2561]🚀Update rocketmq-tools crate category🔥 by @mxsm in #2562
• [ISSUE #2563]📝Update rocketmq-rust version to 0.5.0 for next develop🔥 by @mxsm in #2564
• [ISSUE #2565]📝Add v0.4.0 release note doc🔥 by @mxsm in #2566
• [ISSUE #2567]📝Update Release note latest version🔥 by @mxsm in #2568
• [ISSUE #2569]📝Update relase v0.5.0 doc🔥 by @mxsm in #2570
• Add QueueTimeSpan and MessageTrack by @decadezzz in #2560
• [ISSUE #2573]Optimize package script by @mxsm in #2574
• [ISSUE #2503 ] RemotingCommand some methods add #[inline] by @siddheshzz in #2575
• [ISSUE #2576]⚡️Optimize QueueLockManager shutdown🔥 by @mxsm in #2577
• Bump clap from 4.5.29 to 4.5.30 by @dependabot in #2578
• Bump tempfile from 3.16.0 to 3.17.1 by @dependabot in #2579
• [ISSUE #2580]🚀TrackType implement Serialize and Deserialize by @mxsm in #2581
• [Enhancement⚡️] Remove SendMessageProcessor useless code #2584 by @siddheshzz in #2585
• [ISSUE #2586]🔨Update automerge.yml by @mxsm in #2587
• Bump uuid from 1.13.1 to 1.13.2 by @dependabot in #2589
• Bump zstd from 0.13.2 to 0.13.3 by @dependabot in #2593
• Bump serde from 1.0.217 to 1.0.218 by @dependabot in #2592
• Bump anyhow from 1.0.95 to 1.0.96 by @dependabot in #2594
• Bump serde_json from 1.0.138 to 1.0.139 by @dependabot in #2595
• [ISSUE #2582] MessageTrack supports Serialize and Deserialize by @siddheshzz in #2591
• [ISSUE #1675]Optimize MessageListenerOrderly#consume_message method signature by @kamlesh0928 in #2590
• Bump windows from 0.59.0 to 0.60.0 by @dependabot in #2596
• Bump uuid from 1.13.2 to 1.14.0 by @dependabot in #2597
• [ISSUE #2598]🚀Optimize PopMessageProcessor pop_msg_from_queue🔥 by @mxsm in #2599
• [ISSUE #2601]🚀Optimize PopReviveService log print🔥 by @mxsm in #2602
• [ISSUE #2600]🐛QueryAssignmentProcessor request code not correct🔥 by @mxsm in #2603
• Bump flate2 from 1.0.35 to 1.1.0 by @dependabot in #2606
• Bump clap from 4.5.30 to 4.5.31 by @dependabot in #2607
• Bump libc from 0.2.169 to 0.2.170 by @dependabot in #2608
• [ISSUE #2604] Remove AdminBrokerProcessor unused code by @Brijeshthummar02 in #2605
• [ISSUE #2583] Optimize order_count_info String capacity by @siddheshzz in #2611
• Bump chrono from 0.4.39 to 0.4.40 by @dependabot in #2612
• Bump uuid from 1.14.0 to 1.15.1 by @dependabot in #2613
• [ISSUE #2614]🐛Fix ConsumerGroupInfo#update_subscription deadlock by @mxsm in #2615
• [ISSUE #2616]🚀Add Level for log setting🔥 by @mxsm in #2617
• [ISSUE #2619]📝Add Contribute Guide website link🔥 by @mxsm in #2620
• [ISSUE #2618]🐛Fix PopMessageRequestHeader#is_timeout_too_much attempt to subtract with overflow🔥 by @mxsm in #2621
• [ISSUE #2622]💫Change MessageStoreConfig timer_wheel_enable default value from true to false🔥 by @mxsm in #2623
• [ISSUE #2610] Remove ReplyMessageProcessor useless code by @siddheshzz in #2625
• [ISSUE #2626]🐛Fix PopMessageProcessor#process error acording to Java code🔥 by @mxsm in #2627
• [ISSUE #2624]🚀Implement PopMessageProcessor#append_check_point method🔥 by @mxsm in #2628
• [ISSUE #2633]🚀ArcMut implements Debug trait🔥 by @mxsm in #2634
• [ISSUE #2635]📝Update README.md🔥 by @mxsm in #2636
• [ISSUE #2630]🚀Implement PopBufferMergeService#add_ck method🔥 by @mxsm in #2637
• [ISSUE #2631]🚀Implement PopBufferMergeService#add_ck_just_offset method🔥 by @mxsm in #2638
• [ISSUE #2609]🚀Update the version number of the website's homepage to the latest🔥 by @mxsm in #2639
• [ISSUE #2647]⚡️optimize cargo clippy -- -D warnings error by @mxsm in #2648
• Bump anyhow from 1.0.96 to 1.0.97 by @dependabot in #2645
• Bump bytemuck from 1.21.0 to 1.22.0 by @dependabot in #2641
• Bump proc-macro2 from 1.0.93 to 1.0.94 by @dependabot in #2642
• Bump quote from 1.0.38 to 1.0.39 by @dependabot in #2646
• Bump serde_json from 1.0.139 to 1.0.140 by @dependabot in #2640
• Bump syn from 2.0.98 to 2.0.99 by @dependabot in #2643
• Bump thiserror from 2.0.11 to 2.0.12 by @dependabot in #2644
• [ISSUE #2651]🐛Request PopMessage return not response header🔥 by @mxsm in #2652
• [ISSUE #2653]⚡️Remove EscapeBridge useless attributes🍻 by @mxsm in #2654
• Bump bytes from 1.10.0 to 1.10.1 by @dependabot in #2656
• [ISSUE #2632] PopCheckPointWrapper method add #[inline] by @siddheshzz in #2655
• [ISSUE #2657] 🐛PopMessageProcessor#pop_msg_from_queue's atomic_rest_n… by @mxsm in #2658
• Bump tempfile from 3.17.1 to 3.18.0 by @dependabot in #2659
• [ISSUE #2660]⚡️Optimize PopMessageResponseHeader return value by @mxsm in #2661
• [ISSUE #2662]⚡️Remove PopMessageProcessor#append_check_point comments🍻 by @mxsm in #2663
• Bump tokio from 1.43.0 to 1.44.0 by @dependabot in #2664
• Bump ring from 0.17.8 to 0.17.13 by @dependabot in #2666
• [ISSUE #2665]⚡️PopBufferMergeService#scan attempt to subtract with overflow🍻 by @mxsm in #2667
• [ISSUE #2668]🐛PopBufferMergeService start wait time incorrect🍻 by @mxsm in #2669
• Bump clap from 4.5.31 to 4.5.32 by @dependabot in #2672
• Bump once_cell from 1.20.3 to 1.21.0 by @dependabot in #2673
• Bump serde from 1.0.218 to 1.0.219 by @dependabot in #2675
• Bump syn from 2.0.99 to 2.0.100 by @dependabot in #2674
• [ISSUE #2670]🚀Implement PopBufferMergeService#scanCommitOffset method🍻 by @mxsm in #2671
• [ISSUE #2676]🐛Fix PopBufferMergeService#is_ck_done_for_finish logic not correct by @mxsm in #2677
• [ISSUE #2678]🐛Fix PopBufferMergeService#put_offset_queue logic not correct by @mxsm in #2679
• [ISSUE #2680]🐛Fix set PopRequest message_filter some times is none by @mxsm in #2681
• [ISSUE #2683]🚀Implement PopLongPollingService#clean_unused_resource method by @mxsm in #2684
• [ISSUE #2685]📝Update Rocketmq Rust Roadmap🍻 by @mxsm in #2686
• [ISSUE #2687]⚡️Remove PopBufferMergeService print debug log🍻 by @mxsm in #2688
• Bump reqwest from 0.12.12 to 0.12.13 by @dependabot in #2689
• Bump libc from 0.2.170 to 0.2.171 by @dependabot in #2690
• [ISSUE #2691]⚡️Optimize PopLongPollingService#start method logic🍻 by @mxsm in #2692
• Bump quote from 1.0.39 to 1.0.40 by @dependabot in #2693
• Bump reqwest from 0.12.13 to 0.12.14 by @dependabot in #2694
• [ISSUE #2695]🚀Channel adds is_ok methods by @mxsm in #2696
• [ISSUE #2697]⚡️Optimize PopLongPollingService#poll_remoting_commands methods by @mxsm in #2698
• [ISS...

🔊Announcement: RocketMQ Rust 🔖v0.4.0 has been released

New Feature and improve performance

• ✨Fix some bugs
• 🌐 Add rocketmq-rust doc web site
• 🚀 Add new crates: rocketmq-tui and rocketmq-tools
• 🚀 Add some new features

What's Changed

• [ISSUE #1210]✨Update the version to 0.4.0 for development by @mxsm in #1211
• [ISSUE #1212]🐛Fix TopicConfigSerializeWrapper unit test error by @mxsm in #1213
• [ISSUE #1214]🔥Optimize Send message put PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX Property by @mxsm in #1215
• [ISSUE #1216]✅Optimize TransactionalMessageUtil some method⚡️ by @mxsm in #1217
• [ISSUE #1136]🚀Support broker receive transaction message-3 by @mxsm in #1218
• [ISSUE #1219]📝Update README.md by @mxsm in #1220
• [ISSUE #1221]Optimize MappedFile method by @mxsm in #1222
• [ISSUE #1223]Change the return type of the get_transaction_id method in MessageTrait to &CheetahString by @mxsm in #1224
• Bump serde_json from 1.0.132 to 1.0.133 by @dependabot in #1227
• Bump mockall from 0.13.0 to 0.13.1 by @dependabot in #1226
• [ISSUE #1228]🚀Implement Java MessageDecoder class encodeUniquely and encode method by @mxsm in #1229
• [ISSUE #1230]🚀Support broker receive transaction message-4 by @mxsm in #1231
• [ISSUE #1232]Optimize DefaultRequestProcessor code by @mxsm in #1233
• Bump codecov/codecov-action from 5.0.2 to 5.0.3 by @dependabot in #1235
• [ISSUE #1236]Add #[inline] for DefaultRemotingRequestProcessor#process_request by @mxsm in #1237
• [ISSUE #1234]🐛NameServer Cannot drop a runtime in a context where blocking is not allowed by @mxsm in #1238
• [ISSUE #1239]🔥Optimize KVConfigManager code⚡️ by @mxsm in #1240
• [ISSUE #1241]🔨Add Associate Milestone Github Action by @mxsm in #1242
• [ISSUE #1243]🔨Add Associate Milestone Github Action for PR by @mxsm in #1244
• [ISSUE #1245]🔨Update Associate Milestone Github Action CI by @mxsm in #1246
• [ISSUE #1247]🔨Add Sync Issue Labels to PR Github action CI by @mxsm in #1248
• [ISSUE #1249]🍻Optimize RouteInfoManager logic by @mxsm in #1250
• Bump codecov/codecov-action from 5.0.3 to 5.0.6 by @dependabot in #1252
• Bump actions/checkout from 3 to 4 by @dependabot in #1251
• [ISSUE #1254]🚀RocketMQRuntime add schedule_at_fixed_rate_mut method by @mxsm in #1255
• [ISSUE #1256]🔨Update Associate Milestone Github actions CI by @mxsm in #1257
• [ISSUE #1253]⚡️Optimize RouteInfoManager in NameServerBootstrap, remove RouteInfoManager parking_lot::RwLock by @mxsm in #1259
• [ISSUE #1258]🚀Implement RegisterBrokerBody compress encode and decode by @mxsm in #1260
• [ISSUE #1261]⚡️TopicFilterType implement Display by @mxsm in #1262
• [ISSUE #1263]🔨Optimize TopicConfig encode📝 by @mxsm in #1264
• [ISSUE #1265]🐛Fix RegisterBrokerBody decode error by @mxsm in #1266
• [ISSUE #1267]⚡️Optimize Name server DefaultRequestProcessor#query_broker_topic_config by @mxsm in #1268
• Bump tabled from 0.16.0 to 0.17.0 by @dependabot in #1273
• Bump syn from 2.0.87 to 2.0.89 by @dependabot in #1271
• Bump codecov/codecov-action from 5.0.6 to 5.0.7 by @dependabot in #1270
• [ISSUE #1269]⚡️Optimize name server DefaultRequestProcessor#process_register_broker by @mxsm in #1274
• [ISSUE #1275]⚡️Optimize name server DefaultRequestProcessor#get_broker_member_group by @mxsm in #1276
• [ISSUE #1277]⚡️Optimize name server DefaultRequestProcessor#wipe_write_perm_of_broker_by_lock by @mxsm in #1278
• [ISSUE #1279]⚡️Optimize name server DefaultRequestProcessor#get_all_topic_list_from_nameserver by @mxsm in #1280
• [ISSUE #1281]⚡️Optimize name server DefaultRequestProcessor#delete_topic_in_name_srv by @mxsm in #1282
• [ISSUE #1283]⚡️Optimize name server DefaultRequestProcessor by @mxsm in #1284
• [ISSUE #1285]⚡️Optimize name server ClientRequestProcessor#get_route_info_by_topic by @mxsm in #1286
• [ISSUE #1288]⚡️Add doc for MessageSysFlag and optimize code by @mxsm in #1289
• [ISSUE #1303]🚀Add QueryAssignmentRequestBody and QueryAssignmentResponseBody by @mxsm in #1304
• [ISSUE #1305]🚀Add SetMessageRequestModeRequestBody by @mxsm in #1306
• [ISSUE ##1307]🚀Implement MessageRequestModeManager by @mxsm in #1308
• [ISSUE #1310]⚡️Refactor AllocateMessageQueueStrategy by @mxsm in #1311
• [ISSUE #1293]🔥Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMessageQueueAveragelyByCircle🚀 by @mxsm in #1312
• [ISSUE #1313]🔨Update Github Actions CI by @rocketmq-rust-robot in #1314
• Bump cheetah-string from 0.1.5 to 0.1.6 by @dependabot in #1317
• [ISSUE #90]Support update namesrv config by @PanGan21 in #1316
• [ISSUE #1319]🔨Update Github Actions CI by @mxsm in #1320
• Revert "[ISSUE #1319]🔨Update Github Actions CI" by @mxsm in #1325
• Revert "[ISSUE #1313]🔨Update Github Actions CI" by @mxsm in #1326
• [ISSUE #1323]🔨Update Github Actions CI by @rust-learn-now in #1327
• [ISSUE #1321]🧪Add unit test for OperationResult by @shadowsoy in #1322
• [ISSUE #1328]🧪Add test for ConsumerData by @mxsm in #1329
• [ISSUE #1332]🔨Update Github Actions CI by @mxsm in #1333
• [ISSUE #1336]🔨Update Github Actions CI by @mxsm in #1337
• [ISSUE #1330]🧪Add unit test for MessageModel by @rust-learn-now in #1335
• [ISSUE #1340]🔨Update Github Actions CI by @rust-learn-now in #1341
• [ISSUE #1338]🧪Add Unit test for ProducerData by @what-design in #1339
• 🔨Update Github Actions CI by @rust-learn-now in #1344
• [ISSUE #1345]🔨Update Github Actions CI by @mxsm in #1346
• [ISSUE #1342]🧪Add Unit test for BrokerMemberGroup by @ButterflyEffect1991 in #1343
• [ISSUE #1349]🔨Update Github Actions CI by @ButterflyEffect1991 in #1350
• [ISSUE #1352]🔨Update Github Actions CI by @rust-learn-now in #1353
• [ISSUE #1347]🧪Add unit test for route_data_view by @ButterflyEffect1991 in #1348
• [ISSUE #1354]🔨Update Github Actions CI by @rust-learn-now in #1355
• [ISSUE #1356]🧪Add unit test for CreateTopicRequestHeader by @Fly-cmd-ops in #1357
• [ISSUE #1358]🔨Update Github Actions CI by @mxsm in #1359
• [ISSUE #1360]🧪Add unit test for DeleteTopicRequestHeader by @Fly-cmd-ops in #1361
• [ISSUE #1362]🎨Refactor QueryAssignmentProcessor by @mxsm in #1363
• [ISSUE #1364]🍻Broker Supports request code SetMessageRequestMode (401) by @mxsm in #1365
• [ISSUE #1368]📝Update README.md by @mxsm in #1369
• [ISSUE #1370]🚀Add PlainAccessConfig by @mxsm in #1371
• [ISSUE #1372]🚀Add ClusterAclVersionInfo by @mxsm in #1373
• [ISSUE #1374]🚀Add CheckRocksdbCqWriteProgressResponseBody and ProducerConnection by @mxsm in #1375
• [ISSUE #1387]🚀Add rocketmq-tools crate🔥 by @mxsm in #1388
• [ISSUE #1389]🔨Update package and publish script🔊 by @mxsm in #1390
• [I...

🔊rocketmq-rust-all-0.3.0 🚀 Release

New Feature and improve performance

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

What's Changed

• [ISSUE #427]⬆️Upgrade the version to 0.3.0 for the next version's feature development📌 by @mxsm in #428
• [ISSUE #429]⬆️Upgrade the version to 0.3.0 for the next version's feature development📌 by @mxsm in #430
• [ISSUE #431]🔨Add rocketmq rust crate package and publish scripts🔨 by @mxsm in #432
• [ISSUE #433]👷Improving Methods of TopicQueueMappingManager Struct by @mxsm in #434
• [ISSUE #435]⚡️Improving broker receive a single message🎨 by @mxsm in #436
• [ISSUE #437]🔥Remove useless code by @shadowsoy in #438
• [ISSUE #439]⚡️Implementing Functionality Methods of HookUtils.java🎨 by @mxsm in #440
• [ISSUE #441]🔥Improving PutMessageHook logic🚀 by @mxsm in #442
• [ISSUE #443✅]Add test case for BloomFilterData💚 by @flydream-ylgw in #444
• [ISSUE #445]✅Add test case for ConsumeFromWhere by @yulanggongwu in #446
• [ISSUE #447]✨ Add stats struct by @SpaceOneT in #448
• [ISSUE #449]🎨Optimize SendMessageProcessor#process_request method by @yulanggongwu in #450
• [ISSUE #451] ✨Add MomentStatsItem struct 🚀 by @flydream-ylgw in #452
• [ISSUE #453] 🚧Add StatsSnapshot struct by @flydream-ylgw in #454
• [ISSUE #455] ✨Add CallSnapshot struct by @antcarryele in #456
• [ISSUE #457]🚀Enhance the functionality of BrokerStatsManager by @mxsm in #458
• [ISSUE #459]🚀Enhance the functionality of BrokerStatsManager -2🎨 by @mxsm in #460
• [ISSUE #461]🎉Add StatisticsItem struct 🎉 by @flydream-ylgw in #462
• [ISSUE #463] ✨Add StatisticsItemFormatter struct by @flydream-ylgw in #464
• [ISSUE #465]🔖Enhance the functionality of BrokerStatsManager -3 by @mxsm in #466
• [ISSUE #467]🔥Optimize broker start and init by @mxsm in #468
• [ISSUE #469]🚀Develop BrokerRuntime initializeBrokerScheduledTasks🚀 by @mxsm in #470
• [ISSUE #471]🔥Optimize Broker start🚑️ by @mxsm in #472
• [ISSUE #473]🎨Reformat the code🎨 by @mxsm in #474
• [ISSUE #475]🔧Add Cargo.lock💡 by @mxsm in #476
• [ISSUE #477]✅Add test case for BrokerAddrInfo and BrokerStatusChangeInfo 🚀 by @ButterflyEffect1991 in #478
• [ISSUE #479]🔥Optimize broker register and client scan_available_name_srv🎨 by @mxsm in #480
• Bump bytes from 1.5.0 to 1.6.0 by @dependabot in #482
• Bump proc-macro2 from 1.0.76 to 1.0.85 by @dependabot in #491
• Bump anyhow from 1.0.79 to 1.0.86 by @dependabot in #490
• Bump clap from 4.4.17 to 4.5.7 by @dependabot in #489
• Bump quote from 1.0.35 to 1.0.36 by @dependabot in #487
• Bump tokio-util from 0.7.10 to 0.7.11 by @dependabot in #486
• Bump thread_local from 1.1.7 to 1.1.8 by @dependabot in #484
• Bump parking_lot from 0.12.2 to 0.12.3 by @dependabot in #488
• Bump tokio-stream from 0.1.14 to 0.1.15 by @dependabot in #485
• Bump serde_json from 1.0.111 to 1.0.117 by @dependabot in #483
• [ISSUE #481] 🍻Optimize error handle by @TeslaRustor in #492
• [ISSUE #493] 🍻Optimize broker out api registers broker by @mxsm in #494
• [ISSUE #495]🚀Optimize RemotingClient trait by @TeslaRustor in #496
• [ISSUE #497]🐛Ensure compatibility with the deserialization of lower versions of HeartbeatData by @flydream-ylgw in #498
• [ISSUE #499]🎨Add default value for struct by @mxsm in #500
• [ISSUE #501] ✅Add test case for HeartbeatData by @flydream-ylgw in #502
• Bump syn from 2.0.48 to 2.0.66 by @dependabot in #507
• Bump crc32fast from 1.3.2 to 1.4.2 by @dependabot in #506
• Bump tokio from 1.35.1 to 1.38.0 by @dependabot in #505
• Bump thiserror from 1.0.56 to 1.0.61 by @dependabot in #504
• Bump serde from 1.0.195 to 1.0.203 by @dependabot in #503
• [ISSUE #508] ✨Add fast broker server by @shadowsoy in #509
• [ISSUE #510]✨Broker supports batch message storage🚀 by @mxsm in #511
• [ISSUE #512]🔥Implementing Functionality do append batch messages🚀 by @shadowsoy in #513
• [ISSUE #514]🚀Add CodeRabbit 🔨 by @mxsm in #515
• [ISSUE ##516]✅Add test case for StoreType 🚧 by @shadowsoy in #517
• [ISSUE #518]🚀Optimzie get data from Bytes by @mxsm in #519
• [ISSUE #520] 🐛Fix count_inner_msg_num method of message decoder mode by @dream-cloud-fly in #521
• Bump codecov/codecov-action from 4.4.1 to 4.5.0 by @dependabot in #522
• [ISSUE ##523] 🔨Add auto request review by @mxsm in #524
• [ISSUE ##525]🔨 Add auto comment on PR by @mxsm in #526
• [ISSUE #529]🔨Optimize Auto Comment on PR by @mxsm in #530
• [ISSUE ##527]🔨Optimize auto request review by @mxsm in #528
• [ISSUE ##531] 🎨Optimize thread local code by @shadowsoy in #532
• [ISSUE # #533] 🔨Optimize auto request review config file by @shadowsoy in #534
• [ISSUE #537]🔨Optimize auto request review config file by @mxsm in #538
• [ISSUE #535]✅Add test case for CleanupPolicy by @shadowsoy in #536
• [ISSUE #539]🔨Optimize Auto Comment on PR by @mxsm in #540
• [ISSUE #542]🔨Add auto add label for pr approval by @mxsm in #543
• [ISSUE #541]🔨Add Auto-Merge by @mxsm in #544
• [ISSUE #545]🔧Update label-on-approval.yml by @mxsm in #546
• [ISSUE #547]🔧Update automerge.yml by @mxsm in #548
• [ISSUE #549]🔧Update automerge.yml by @mxsm in #550
• [ISSUE #553]🔧Update workflows config file by @mxsm in #554
• [ISSUE #551]🔥Remove useless code by @dream-cloud-fly in #552
• [ISSUE #555]🔨Update label-on-approval.yml by @mxsm in #556
• [ISSUE #560]🔧Update workflows config file by @mxsm in #561
• [ISSUE #565]🔨Update label-on-approval.yml by @flydream-ylgw in #566
• [ISSUE #563]🔧Update auto-comment-pr.yml by @ButterflyEffect1991 in #564
• [ISSUE #568]🔨Update label-on-approval.ym by @mxsm in #569
• Update label-on-approval.yml by @mxsm in #571
• Update label-on-approval.yml by @mxsm in #573
• Update label-on-approval.yml by @mxsm in #576
• Update label-on-approval.yml by @mxsm in #577
• Update label-on-approval.yml by @mxsm in #581
• Update config file by @mxsm in #582
• Update config file by @mxsm in #584
• update config file by @mxsm in #587
• update config file by @mxsm in #588
• update config file by @mxsm in #589
• Update automerge.yml by @mxsm in #591
• Update automerge.yml by @mxsm in #594
• Update automerge.yml by @mxsm in #596
  *...

🚀Feature🎉

🎉🎉🎉🎉

1. Perfect the Name Server

2. Develop the message storage module

3. Develop the Broker module

4. Support single message sending, etc.

What's Changed

• [ISSUE #127]⬆️Upgrade the version to 0.2.0 for the next version's feature development by @mxsm in #128
• [ISSUE #129]🥚Define macros to handle common code for RequestHeader by @mxsm in #130
• [ISSUE #131]🤡init broker and store crate by @mxsm in #132
• [ISSUE #133]🔧Add rocketmq store config by @mxsm in #134
• [ISSUE #135]🚧Define rocketmq Message by @mxsm in #136
• [ISSUE #137]🚀Define the rust version of Messagestore based on the Java version of MessageStore by @mxsm in #138
• [ISSUE #141]💥Add Broker command line parse by @mxsm in #142
• [ISSUE #140]🎨Add Broker bootstrap by @mxsm in #143
• [ISSUE #144]🎉Add the basic code for local file in the store module by @mxsm in #145
• [ISSUE #146]📈Add Broker start method and optimize some code by @mxsm in #147
• [ISSUE #148]📝Add issue template by @mxsm in #149
• [ISSUE #150]Update ISSUE TEMPLATE by @mxsm in #151
• Revert "[ISSUE #150]Update ISSUE TEMPLATE" by @mxsm in #152
• [ISSUE #150]🚀Update ISSUE TEMPLATE and some markdown doc by @mxsm in #153
• [ISSUE #154]Add ConfigManage code by @mxsm in #155
• [ISSUE #156]📝Add pull resquest template by @mxsm in #157
• [ISSUE #158]🚀Add some Implementations for ConfigManager trait by @mxsm in #159
• [ISSUE #160]💥BrokerController initialization method implementation by @mxsm in #161
• [ISSUE #162]📝Add Broker README.md by @antcarryele in #164
• [ISSUE #165]🐛Fix Broker start error by @mxsm in #166
• [ISSUE #167]👍Add TopicConfigManager#init method by @mxsm in #168
• [ISSUE #170](🎉Happy Chinese New Year🎉)mplementing network communication for the Broker-1 by @mxsm in #171
• [ISSUE #173](🎉Happy Chinese New Year🎉)Implementing network communication for the Broker-2 by @mxsm in #174
• [ISSUE #175]👷Update GitHub Actions CI by @mxsm in #176
• [ISSUE #177]♻️Refactor net model by @mxsm in #178
• [ISSUE #179]📝Add project icon by @mxsm in #180
• [ISSUE #181]💚Add codecov ci by @mxsm in #182
• [ISSUE #183]💚Add codecov ci yml by @mxsm in #184
• [ISSUE #187]📝Add some icon into README.md by @mxsm in #188
• [ISSUE #189]📝Update README.md by @mxsm in #190
• [ISSUE #191]🚀Implementing network communication for the Broker-3 by @mxsm in #192
• [ISSUE #193]📝Update README.md by @mxsm in #194
• [ISSUE #195]🚀Refactor remoting net by @mxsm in #196
• [ISSUE #197]🐛Fix Name server shutdown throw exception by @mxsm in #198
• [ISSUE #199]Broker net model develop by @mxsm in #200
• [ISSUE #201]🐛Fix Use RequestHeaderCodec macro cannot find type HashMap in this scope by @mxsm in #202
• [ISSUE #203]🐛Fix RequestHeaderCodec macro can not work by @mxsm in #204
• [ISSUE #169]🚀Implementing network communication for the Broker by @mxsm in #205
• [ISSUE #207]Support send message and send message v2(request code:10,310)-1 by @mxsm in #208
• [ISSUE #210]🔧Add dependabot.yml by @antcarryele in #211
• Update config requirement from 0.13 to 0.14 by @dependabot in #212
• Update env_logger requirement from 0.10.0 to 0.11.2 by @dependabot in #213
• Bump codecov/codecov-action from 4.0.1 to 4.0.2 by @dependabot in #214
• [ISSUE #209]Support send message and send message v2(request code:10,310)-2 by @mxsm in #215
• [ISSUE #218]📌Implement DefaultMappedFile initialization by @mxsm in #219
• [ISSUE #220]🚀Implement MessageStore put message-1 by @mxsm in #221
• [ISSUE #224]🎨Using cfg to solve the problem that the MessageStore trait cannot be converted to an object by @mxsm in #225
• [ISSUE #223]🚧Implement MessageStore put message(single message)-2 by @mxsm in #226
• Bump codecov/codecov-action from 4.0.2 to 4.1.0 by @dependabot in #228
• [ISSUE #227]🚧Implement MessageStore put message(single message)-3 by @mxsm in #229
• [ISSUE #232]🐛Fix CI fails to pass the check on the latest version of Rustc by @mxsm in #233
• [ISSUE #230]🍻Implement MessageExtEncoder by @mxsm in #231
• [ISSUE #234]🚧Implement AppendMessageCallback-1 by @mxsm in #235
• [ISSUE #236]✨Create bytebuf crate for bytes operate by @mxsm in #237
• Revert "[ISSUE #236]✨Create bytebuf crate for bytes operate" by @mxsm in #239
• [ISSUE #240]🎨Optimize broker main code by @mxsm in #241
• [ISSUE #242]🚀Implement DefaultMappedFile related functions-1 by @mxsm in #243
• [ISSUE #244]🚧Implement TopicConfigManager load method by @mxsm in #245
• [ISSUE #246]📌Implement ConfigManager config_file_path method by @mxsm in #247
• [ISSUE #249]🚀Init rocketmq-filter crate by @mxsm in #250
• [ISSUE #251]🎨Fix code style error in latest rust nightly version by @mxsm in #252
• [ISSUE #248]💥Implement ConfigManager decode method by @mxsm in #253
• [ISSUE #254]🎨Format code style by @TeslaRustor in #255
• [ISSUE #256]🐛Fix rust file link by @mxsm in #257
• [ISSUE #258]Fix loading config File error by @mxsm in #259
• [ISSUE #260]🐛Fix When broker shutdown will throw exeception by @mxsm in #261
• [ISSUE #263]🚧Support register borker(request code:103)-1 by @TeslaRustor in #264
• [ISSUE #]🚀Implement CompletableFuture by @mxsm in #266
• [ISSUE #267]✅Add test case for CompletableFuture by @mxsm in #268
• [ISSUE #270]✨Implement remoting client-1 by @TeslaRustor in #271
• [ISSUE #272]🚀Implement remoting client-2 by @mxsm in #273
• [ISSUE #274]🚀Implement remoting client-3 by @mxsm in #275
• [ISSUE #276]🐛Fix client send message error by @TeslaRustor in #277
• [ISSUE #278]🚀Using pub to modify RemotingClient by @TeslaRustor in #279
• [ISSUE #280]⚡️Optimize TokioExecutorService by @mxsm in #281
• [ISSUE #282]🚀Support register borker(request code:103)-2 by @mxsm in #283
• [ISSUE #284]🚧Support register borker(request code:103)-3 by @mxsm in #285
• [ISSUE #286]🎨Replace RequestProcessor#process_request &mut self with &self by @mxsm in #287
• [ISSUE #288]🎨Optimize ArcProcessorTable code by @TeslaRustor in #289
• [ISSUE #290]🎨Optimize RocketmqDefaultClient code by @mxsm in #291
• Bump codecov/codecov-action from 4.1.0 to 4.1.1 by @dependabot in #292
• [ISSUE #293]🎨Change RemotingService start method &mut seft to &self by @mxsm in #294
• [ISSUE #295]Refactor network section code by @mxsm in #296
• [ISSUE #297]🎨Optimize code struct by @mxsm in #298
• [ISSUE #262]🚀Support register borker(request code:103) by @mxsm in #299
• Bump codecov/codecov-action from 4.1.1 to 4.2.0 by @dependabot in https://github.com/...

What's Changed

• [ISSUE #2] explain develop plan by @mxsm in #3
• [ISSUE #4]Namesrv support broker registration and get cluster info request code by @mxsm in #5
• [ISSUE #7]Update README.md doc by @mxsm in #8
• [ISSUE #9]Optimize README.md by adding contributor badges and information about related issues by @mxsm in #10
• [ISSUE #13]Fix code warnings and errors according to Rust Clippy recommendations by @mxsm in #14
• [ISSUE #11]Update ci.yml by @mxsm in #12
• [ISSUE #15]Update README.md doc by @mxsm in #16
• [ISSUE #18]Update CI to support stable Rust version by @mxsm in #19
• [ISSUE #6]Optimize the deserialization of RemotingCommand by @mxsm in #17
• [ISSUE #21]Update README.md doc by @mxsm in #22
• [ISSUE #20]Abstracting the server and client and implementation by @mxsm in #23
• [ISSUE #25]Update README.md doc by @mxsm in #26
• [ISSUE #27]Correcting typos in the documentation by @mxsm in #28
• [ISSUE #24]Fully support broker registration(request code 103) by @mxsm in #29
• [ISSUE #30]Update README.md doc by @antcarryele in #31
• [ISSUE #32]Refactor remoting server by @mxsm in #33
• [ISSUE #34] Update README.md doc about how to start name server by @SpaceXCN in #35
• [ISSUE #36]Support current dir as rocketmq home by @mxsm in #37
• [ISSUE #38]Support get route info by topic(requst code 105) by @mxsm in #39
• [ISSUE #45]Update README.md doc by @mxsm in #46
• [ISSUE #44]Optimize request code get logic by @mxsm in #47
• [ISSUE #48]Add README.md doc for rocketmq-namesrv crate by @mxsm in #49
• [ISSUE #40]Support put kv config(request code 100) by @mxsm in #50
• [ISSUE #51]Update README.md doc by @antcarryele in #52
• [ISSUE #53]Perfect support broker register(request code 103) by @mxsm in #54
• [ISSUE #58]Fix failed to execute the put kv configuration on namesrv by @TeslaRustor in #59
• [ISSUE #60] Namesrv supports get kv config(request code 101) by @mxsm in #61
• [ISSUE #62]Namesrv support delete kv config(request code 102) by @mxsm in #63
• [ISSUE #64]Namesrv support query data version (request code 322) by @mxsm in #66
• [ISSUE #69]Update Namesrv crate README.md doc by @SpaceOneT in #70
• [ISSUE #65]Namesrv support broker heartbeat(request coe 904) by @mxsm in #71
• [ISSUE #68] 🎨 Namesrv support get broker cluster info(request code 106) by @mxsm in #73
• [ISSUE #74] 🚩 Namesrv support wipe write perm of boker(request code 205) by @mxsm in #77
• [ISSUE #78] 📝 Update README.md doc by @antcarryele in #79
• [ISSUE #75] 🚀 Namesrv support add write perm of brober (request code 327) by @mxsm in #80
• [ISSUE #76] ✨ Namesrv supports get all topic list from name server(request code 206) by @mxsm in #81
• [ISSUE #82] 🚀 Namesrv support delete topic in namesrv (request code 216) by @mxsm in #92
• [ISSUE #83] 🚩 Namesrv support register topic in namesrv (request code 217) by @TeslaRustor in #93
• [ISSUE #84] ⚡ Namesrv support get kv list by namespace (request code 219) by @mxsm in #94
• [ISSUE #85] 🚀 Namesrv support get topics by cluster (request code 224) by @mxsm in #95
• [ISSUE #86]🎉Namesrv support get system topic list (request code 304) by @mxsm in #96
• [ISSUE #87]🏷️Namesrv support get unit topic list (request code 311) by @mxsm in #97
• [ISSUE #88]📝Namesrv support get has unit sub topic list (request code 312) by @mxsm in #98
• [ISSUE #89]💚Namesrv support get has unit sub ununit topic list (request code 313) by @mxsm in #99
• [ISSUE #101]♻️Refactor thread pool by @mxsm in #102
• [ISSUE #100]⚡️Add Schedule Service to do scan not active broker by @mxsm in #103
• [ISSUE #57]🍻Namesrv support broker unregister(request code 104)🚀 by @mxsm in #104
• Revert "[ISSUE #57]🍻Namesrv support broker unregister(request code 104)🚀" by @mxsm in #105
• [ISSUE #57]🍻Namesrv support broker unregister(request code 104)🚀 by @mxsm in #106
• [ISSUE #107] 🔧 Add parsing configuration files for Namesrv by @mxsm in #108
• [ISSUE #109]🐛 Fix shutdown the namesrv throw execption 🚀 by @mxsm in #110
• [ISSUE #111]🔊Add some print logs by @mxsm in #112
• [ISSUE #113]🐛Fix unregister broker fail(request code 104) by @mxsm in #114
• [ISSUE #115]🚀Client disconnected and deregistered from Broker 🚀 by @mxsm in #116
• [ISSUE #117]🐛Fix can not get Route info by topic(requst code 105) by @mxsm in #118
• [ISSUE #119]Update crate Cargo.toml by @mxsm in #120
• [ISSUE #121] Rename crate rocketmq to rocketmq-rust by @mxsm in #122
• [ISSUE #123]Update internal dependency versions by @mxsm in #124
• [ISSUE #125]📝Add README.md for every crate by @mxsm in #126

New Contributors

• @antcarryele made their first contribution in #31
• @SpaceXCN made their first contribution in #35
• @TeslaRustor made their first contribution in #59
• @SpaceOneT made their first contribution in #70

Full Changelog: https://github.com/mxsm/rocketmq-rust/commits/v0.1.0