## mxsm/rocketmq-rust — v0.8.0…v0.9.0

_261+ commits._

### Features
- **[ISSUE #7444]add multiple consumer and producer examples; enhance documentation and structure in README (#7445)** (3053ebb)
- **[ISSUE #7442]♻️refactor: standardize command names and improve output formatting; add new container commands for broker management (#7443)** (3544c37)
- **[ISSUE #7435]✨enhance TLS error handling and add reply topic generation; improve RPC hook propagation in consumers (#7436)** (3612733)
- **[ISSUE #7433]🚀feat: add TLS configuration support for RocketMQ client and server (#7434)** (26af1de)
- **[ISSUE #7428]🚀add request context module and enhance authorization features; include user and ACL retrieval methods, improve RPC hook registration, and update broker configuration for better authentication management (#7429)** (df4999c)
- **[ISSUE #7425]🚀implement broker heartbeat management; add support for recording broker heartbeats, removing inactive brokers, and updating broker live info; enhance related types and methods for better broker lifecycle handling (#7426)** (c67873c)
- **[ISSUE #7417]✨enhance TUI with animation features; add animation tick management, improve focus styles, and update UI elements for better user experience (#7418)** (e35ba44)
- **[ISSUE #7414]🚀add initial implementation of frontend components and API integrations for RocketMQ Dashboard; includes authentication, consumer, producer, and message handling features (#7415)** (f083632)
- **[ISSUE #7409]🚀enhance RocksDB configuration with new options for write buffer size, WAL recovery mode, and improved path handling for consume queues; refactor related components for better integration (#7410)** (906c786)
- **[ISSUE #7407]🚀add RocksDB store support with enhanced configuration options, metrics, and batch operations; refactor existing components for improved integration (#7408)** (b18d43a)
- **[ISSUE #7404]✨enhance UI components for login and producer views; improve accessibility and user experience with new icons and layout adjustments (#7405)** (dfeb9be)
- **[ISSUE #7402]🚀add consume queue functionality with batch processing and offset management; refactor UI components for improved styling and structure (#7403)** (0059724)
- **[ISSUE #7397]🚀add RocksDB integration with batch operations, column family management, and configuration options (#7398)** (0dd7f89)
- **[ISSUE #7393]📝add Google AdSense script to docusaurus.config.ts and update type for description in HomepageFeatures.tsx (#7394)** (6f3c0db)
- **[ISSUE #7391]📝add ads.txt file for Google AdSense integration (#7392)** (005a266)
- **[ISSUE #7389]🚀add authentication metrics and improve authorization error handling; integrate auth metrics into observability framework (#7390)** (c1188de)
- **[ISSUE #7386]🚀add observability metrics for authentication and authorization processes; enhance ACL file watcher shutdown behavior (#7387)** (e89d2a5)
- **[ISSUE #7384]✨enhance error handling for authentication and authorization; add validation for user subjects in ACL operations (#7385)** (94669b6)
- **[ISSUE #7382]🚀add list users and list ACL request handlers with empty response handling; enhance user update permissions check (#7383)** (cc2c535)
- **[ISSUE #7380]🚀add error handling for malformed requests and enhance debug output to redact sensitive information (#7381)** (fc06f58)
- **[ISSUE #7377]♻️refactor controller test port allocation and add related tests (#7378)** (a6da66c)
- **[ISSUE #7373]🚀add data version management for global white remote addresses and refactor error response handling (#7374)** (58ffb09)
- **[ISSUE #7369]🚀add FileAclConfigStore for managing global white remote addresses with persistence and validation (#7370)** (e1cd9af)
- **[ISSUE #7367]🚀add global white address configuration support with update handler and validation (#7368)** (8ce52d8)
- **[ISSUE #7365]🚀add ACL fingerprinting support for configuration loading and validation (#7366)** (1e6eae3)
- **[ISSUE #7361]🚀add support for configurable signature algorithms and request timestamp validation in authentication (#7362)** (48d7854)
- **[ISSUE #7358]✨add ACL configuration support with file loading and watch functionality (#7359)** (8f489be)
- **[ISSUE #7354]🚀add ACL configuration and validation modules, including file loading and permission handling (#7355)** (7014fe9)
- **[ISSUE #7345]✨add tests for signature calculation and request content combination, ensuring compatibility with Java implementations (#7346)** (24d6ab0)
- **[ISSUE #7339]✨add tiered storage feature with configuration and testing support (#7340)** (83e2768)
- **[ISSUE #7337]✨add commit log recovery service and enhance dispatch request validation (#7338)** (a27b26e)
- **[ISSUE #7335]✨add support for topic and queue deletion in metadata store, enhancing cleanup capabilities (#7336)** (740d1ea)
- **[ISSUE #7333]🚀implement asynchronous offset retrieval by timestamp with boundary support for tiered storage (#7334)** (584a491)
- **[ISSUE #7331]✨add tiered storage configuration validation and startup info logging (#7332)** (03b5068)
- **[ISSUE #7327]✨enhance tiered storage integration by adding configuration support and improving index management logic (#7328)** (906f9c3)
- **[ISSUE #7323]🚀add index file management for tiered storage, including entry appending, loading, and compaction logic (#7324)** (c73d336)
- **[ISSUE #7310]🚀add initial implementation of tiered storage for RocketMQ in Rust, including core traits, metadata models, and file segment management (#7311)** (1d8037e)
- **[ISSUE #7308]🚀add topic statistics retrieval and display in dashboard, including new data structures and UI components for topic metrics (#7309)** (655781d)
- **[ISSUE #7305]♻️refactor broker stats retrieval methods for improved readability and add compact card display for TPS metrics in dashboard (#7306)** (fdb4c88)
- **[ISSUE #7301]🚀add dashboard charts and data fetching logic for broker and topic overview (#7302)** (9f2353f)
- **[ISSUE #7299]✨enhance string_to_properties function to accept both '=' and ':' as separators and add corresponding unit tests (#7300)** (0bbacf8)
- **[ISSUE #7295]✨add new example for request code smoke test and improve error message formatting in various modules (#7296)** (bab2acf)
- **[ISSUE #7225] Add unit tests for NetworkUtil in rocketmq-common (#7294)** (51b1265)
- **[ISSUE #7292]✨add support for Java-compatible numeric keys in topic queue mapping and enhance timer properties handling (#7293)** (f458ac2)
- **[ISSUE #7286]✨enhance cold data flow control with new accumulator structure and global tracking (#7287)** (fd59ac0)
- **[ISSUE #7284]✨add Java-compatible field names and improve deserialization for GroupList and TopicRouteData (#7285)** (2bfb2d8)
- **[ISSUE #7282]✨add Java-compatible encoding for ConsumeStats and ConsumeStatsList (#7283)** (9543574)
- **[ISSUE #7280]✨update ACL actions handling to support array format and improve deserialization logic (#7281)** (a52871e)
- **[ISSUE #7278]♻️refactor transaction check logic and add new utility functions for immunity handling (#7279)** (1d103a8)
- **[ISSUE #7276]✨add timeout constant and improve error messaging for push reply handling (#7277)** (23b96ff)
- **[ISSUE #7274]✨add transaction end header building and validation for consumer requests (#7275)** (dec4a44)
- **[ISSUE #7272]🚀add reset consumer client offset and get consumer status request handling (#7273)** (8fee047)
- **[ISSUE #7268]🚀add support for NotifyUnsubscribeLite request handling and validation (#7269)** (5060fbf)
- **[ISSUE #7266]🧪add protocol compatibility tests for Java request and response codes (#7267)** (27a3461)
- **[ISSUE #7264]✨add user authentication request handling and response code mappings (#7265)** (e4fb1cc)
- **[ISSUE #7262]🚀streamline mapping detail checks and add new message processing functions (#7263)** (33fc3de)
- **[ISSUE #7260]✨add new request processing functions and improve broker registration logic (#7261)** (a44d194)
- **[ISSUE #7258]🚀add new response codes for controller and user authentication (#7259)** (fe24fad)
- **[ISSUE #7254]✨Add timer RocksDB configuration and improve request handling (#7255)** (915e46c)
- **[ISSUE #7250]✨enhance(local_file_consume_queue_store, local_file_message_store): add RocksDB compatibility for consume queues and improve queue type handling (#7251)** (7918fc9)
- **[ISSUE #7246]✨enhance(local_file_message_store): add recovery states and improve lifecycle management during recovery phases (#7247)** (f2a62ba)
- **[ISSUE #7238]✨enhance(message_store, local_file_message_store): add HA runtime info retrieval and improve disk space management logic (#7239)** (ca26fe7)
- **[ISSUE #7220]🚀feat(local_file_message_store, single_consume_queue): add boundary timestamp query and improve message encoding logic (#7221)** (cb8ea97)
- **[ISSUE #7202]✨enh(broker): add tests for fast failure queue handling and Java fast failure key deserialization (#7203)** (e129def)
- **[ISSUE #7200]🚀feat(broker): add fast failure configuration and implement request handling for broker queues (#7201)** (b0f005d)
- **[ISSUE #7196]✨enh(stats): add benchmarks for StoreStatsService performance and runtime info (#7197)** (4efa09b)
- **[ISSUE #7194]✨enh(stats): improve message handling statistics and add concurrency support (#7195)** (317b4c1)
- **[ISSUE #7189]🚀enh(ui): enhance command tree rendering and add viewport management (#7190)** (0bb027f)
- **[ISSUE #7187]✨enhance input handling and add tests for namesrv and search functionalities (#7188)** (e85ded1)
- **[ISSUE #7185]🚀feat(tests): add comprehensive tests for command catalog functionalities (#7186)** (c1a2b60)
- **[ISSUE #7183]🚀feat(message): add direct consume and message track functionalities (#7184)** (a5e5dc5)
- **[ISSUE #7181]🚀feat(container, controller): add broker management requests and implement elect master functionality (#7182)** (9cf2ad0)
- **[ISSUE #7179]🚀feat(export): add export metrics command for broker runtime metrics aggregation (#7180)** (76c7af7)

### Backend
- **[ISSUE #7446]🔨update dependencies to version 0.9.0 and adjust project count in publish scripts (#7447)** (d54cf42)
- **[ISSUE #7440]♻️refactor: enhance broker endpoint handling and improve route response logic; update proto package naming conventions (#7441)** (b0b0a4f)
- **[ISSUE #7437]♻️refactor: migrate to OpenRaft implementation; remove legacy raft-rs references and update related documentation (#7439)** (55b9efb)
- **[ISSUE #7431]✨Comprehensively improve rocketmq-client (#7432)** (9ee17fe)
- **[ISSUE #7423]✨update documentation for rocketmq-dashboard-web; clarify backend and frontend validation processes and project structure (#7424)** (e5c2760)
- **[ISSUE #7363]♻️refactor error mapping functions to preserve error categories in authorization handling (#7364)** (5db5ce4)
- **[ISSUE #7341]✨disable auto incremental review in coderabbit configuration (#7342)** (040af17)
- **[ISSUE #7343]🔖bump version to 0.9.0 for all dependencies in Cargo.toml (#7344)** (d92f2b0)
- **[ISSUE #7329]♻️refactor message retrieval logic to utilize get_buffer method for improved efficiency and readability (#7330)** (e1c52aa)
- **[ISSUE #7325]♻️refactor shutdown logic for message store and HA services, adding timeout handling and improving connection management (#7326)** (41be942)
- **[ISSUE #7321]🚀implement index management for tiered storage, including index entry structure, querying, and cleanup logic (#7322)** (4f30189)
- **[ISSUE #7312]🚀implement tiered storage features for RocketMQ, including segment management, metadata handling, and message retrieval enhancements (#7313)** (c969be7)
- **[ISSUE #7303]🚀implement proxy management features including adding, switching, and deleting proxy addresses with corresponding UI updates (#7304)** (c22f0f9)
- **[ISSUE #7297]🐛update styling for message track list in MessageDetailModal to enhance visual consistency (#7298)** (e2dca09)
- **[ISSUE #7290]♻️refactor consume stats encoding to use Java-compatible keys and improve deserialization logic (#7291)** (c8ebdc7)
- **[ISSUE #7288]✨improve error handling in broker handlers by ensuring proper initialization checks for replicas manager and message store (#7289)** (73bfc97)
- **[ISSUE #7270]♻️refactor RocksDB config export handling to return unsupported backend response (#7271)** (e7107a4)
- **[ISSUE #7256]✨improve cache residency tracking and metrics reporting (#7257)** (7077036)
- **[ISSUE #7252]✨enhance(allocate_mapped_file_service, commit_log, local_file_message_store): integrate warm mapped file configuration and improve file allocation logic (#7253)** (5430057)
- **[ISSUE #7248]🚀feat(compaction_service, compaction_store, local_file_message_store): implement compaction service and dispatcher for improved message management (#7249)** (5fa2c50)
- **[ISSUE #7244]✨enhance(broker_runtime, default_flush_manager, local_file_message_store): improve error handling and initialization logic for message stores and services (#7245)** (3d7ac24)
- **[ISSUE #7242]✨enhance(local_file_message_store): improve multi-dispatch handling and offset management logic (#7243)** (aef829b)
- **[ISSUE #7240]✨enhance(flush_manager, commit_log): implement graceful shutdown logic for improved resource management (#7241)** (768fb78)
- **[ISSUE #7236]✨enhance(default_flush_manager): improve flush and commit logic with async helpers and error handling (#7237)** (0d2689b)
- **[ISSUE #7234]✨enhance(index_service, local_file_message_store): enhance index building logic and improve scheduled task execution (#7235)** (9d89002)
- **[ISSUE #7232]✨enh(index_service): enhance index building logic to skip non-indexable messages and improve transaction handling (#7233)** (e925893)
- **[ISSUE #7193]✨enhancement(rocketmq-broker): remove unused duration_constructors feature gate (#7222)** (5e6094f)
- **[ISSUE #7218]🚀feat(compaction_service, index_service): enhance compaction service initialization and improve index key building logic (#7219)** (a10f837)
- **[ISSUE #7216]♻️refactor(index_file, index_service): improve error handling for index dimensions and enhance index file management (#7217)** (0e5f131)
- **[ISSUE #7214]♻️refactor(append_message_callback, commit_log): improve write position handling and enhance error checks for batch size (#7215)** (d1b69ec)
- **[ISSUE #7212]🚀feat(local_file_message_store): implement store lifecycle management and locking mechanism for message store (#7213)** (a9655cd)
- **[ISSUE #7210]♻️refactor(mapped_file): replace panic handling with Result for mapped file creation and improve error reporting (#7211)** (87ced47)
- **[ISSUE #7208]♻️refactor(service): refactor allocation service to use blocking wakeup mechanism and improve error handling (#7209)** (40b5501)
- **[ISSUE #7206]✨enh(broker): enhance topic queue mapping service with cloning and additional tests (#7207)** (aa46d3f)
- **[ISSUE #7204]🚀feat(broker): implement topic stats and config retrieval from broker (#7205)** (bad3ddb)
- **[ISSUE #7198]✨enh(stats): replace RwLock with DashMap for improved concurrency in StoreStatsService (#7199)** (2cf7d24)
- **[ISSUE #7191]✨enh(ui): improve workspace layout and enhance rendering of command and status panels (#7192)** (1c606ba)

### Chore
- **build(deps): bump smallvec from 1.15.1 to 1.15.2 (#7427)** (c13f718)
- **build(deps): bump uuid from 1.23.2 to 1.23.3 (#7421)** (62c901e)
- **build(deps): bump prost-types from 0.14.3 to 0.14.4 (#7419)** (9b6a69f)
- **build(deps): bump regex from 1.12.3 to 1.12.4 (#7420)** (13b4946)
- **build(deps): bump prost from 0.14.3 to 0.14.4 (#7422)** (50acf2e)
- **build(deps): bump codecov/codecov-action from 6 to 7 (#7416)** (f81211d)
- **build(deps): bump ratatui from 0.29.0 to 0.30.1 (#7412)** (6fec218)
- **build(deps): bump chrono from 0.4.44 to 0.4.45 (#7411)** (2a24164)
- **build(deps): bump tabled from 0.20.0 to 0.21.0 (#7406)** (d03e961)
- **build(deps): bump sysinfo from 0.39.2 to 0.39.3 (#7400)** (4820ce4)
- **build(deps): bump uuid from 1.23.1 to 1.23.2 (#7401)** (c91c3c2)
- **build(deps): bump reqwest from 0.13.3 to 0.13.4 (#7396)** (b103ef1)
- **build(deps): bump opentelemetry_sdk from 0.32.0 to 0.32.1 (#7399)** (fc7bd23)
- **build(deps): bump serde_json from 1.0.149 to 1.0.150 (#7388)** (d46ba91)
- **build(deps): bump local-ip-address from 0.6.12 to 0.6.13 (#7379)** (537d2dd)
- **build(deps): bump dashmap from 6.1.0 to 6.2.1 (#7375)** (779812b)
- **build(deps): bump sysinfo from 0.39.1 to 0.39.2 (#7376)** (4ddbca3)
- **build(deps): bump config from 0.15.22 to 0.15.23 (#7357)** (e54fe1d)
- **build(deps): bump opentelemetry_sdk from 0.31.0 to 0.32.0 (#7353)** (fbee77f)
- **build(deps): bump sysinfo from 0.39.0 to 0.39.1 (#7351)** (085c543)
- **build(deps): bump lz4_flex from 0.13.0 to 0.13.1 (#7347)** (0eee7fe)
- **build(deps): bump hashbrown from 0.17.0 to 0.17.1 (#7348)** (e505c33)
- **build(deps): bump tokio from 1.52.2 to 1.52.3 (#7319)** (bc0e56a)
- **build(deps): bump sysinfo from 0.38.4 to 0.39.0 (#7317)** (8884b0a)
- **build(deps): bump tonic-prost from 0.14.5 to 0.14.6 (#7320)** (24a8601)
- **build(deps): bump tonic-prost-build from 0.14.5 to 0.14.6 (#7318)** (19c5f1c)
- **build(deps): bump tonic from 0.14.5 to 0.14.6 (#7316)** (5492ed2)
- **build(deps): bump rustls-webpki (#7315)** (9f7dbfe)
- **build(deps-dev): bump vite (#7314)** (64419b0)
- **build(deps): bump tokio from 1.52.1 to 1.52.2 (#7307)** (83c1ad1)
- **build(deps): bump actions/setup-node from 4 to 6 (#7227)** (25279e9)
- **build(deps): bump actions/checkout from 4 to 6 (#7230)** (0834661)
- **build(deps): bump codecov/codecov-action from 5 to 6 (#7226)** (6634716)
- **build(deps): bump actions/github-script from 7 to 9 (#7228)** (95974a2)
- **build(deps): bump actions/deploy-pages from 4 to 5 (#7229)** (2bfdab2)
- **build(deps): bump actions/upload-pages-artifact from 3 to 5 (#7231)** (25129b7)
- **build(deps): bump clap_complete from 4.6.2 to 4.6.3 (#7223)** (6c737fc)
- **build(deps): bump reqwest from 0.13.2 to 0.13.3 (#7224)** (8dc30b7)
- **build(deps): bump libc from 0.2.185 to 0.2.186 (#7178)** (80866dc)
- **build(deps): bump local-ip-address from 0.6.11 to 0.6.12 (#7177)** (b434cc0)

_Recap by [Repo Wrapped](https://repowrapped.com/gh/mxsm/rocketmq-rust?utm_source=github-action)._