## mxsm/rocketmq-rust — v0.5.0…v0.6.0

_275+ commits._

### Features
- **[ISSUE #3775]♻️Refactor ConsumerOffsetManager to support generic message store and enhance offset management functionality (#3776)** (a117f1a)
- **[ISSUE #3749]feat(epoch): introduce EpochEntryCache with basic accessors and tests (#3772)** (80c89e0)
- **[ISSUE #3766]📝Add initial broker-simple.toml configuration file with core settings (#3767)** (52d4196)
- **[ISSUE ##1640]Add #[inline] for MessageBatch struct method  (#3754)** (1dae255)
- **[ISSUE #3763]📝Add comprehensive storeConfig section to broker.toml sample (review & cross-doc sync) (#3764)** (3e1177b)
- **[ISSUE #3755]✨Accept mixed-case variants for MessageRequestMode ("Pull"/"Pop") & add tests (#3756)** (be13a29)
- **[ISSUE #3747]♻️Introduce common error module & strict config parsing across broker/namesrv (#3748)** (a09f801)
- **[ISSUE #3745]📝Update broker configuration with enhanced settings and new parameters (#3746)** (d0f4a70)
- **[ISSUE #3743]📝Add configuration files for broker settings in RocketMQ (#3744)** (b279520)
- **[ISSUE #3741]📝Add configuration files for nameserver settings in RocketMQ (#3742)** (54cbe66)
- **[ISSUE #3719]♻️Generalize EnvUtils API & add typed accessors (default/i32/bool) with expanded tests (#3720)** (98513cc)
- **[ISSUE #1290]Add #[inline] for RemotingSysResponseCode method (#3712)** (5267ab8)
- **Refactor MessageExt to add inline attribute (#3711)** (d98bee5)
- **[ISSUE #2917]Add #[inline] for QueryOffsetResult methods (#3680)** (1f3dc74)
- **[ISSUE 2903]Add #[inline] for store_path_config_helper methods (#3677)** (1ef0d1d)
- **[ISSUE #3653]Add links to contributor and license icons (#3652)** (8419f5e)
- **[ISSUE #3593]⚡️Add HAConnectionId struct with UUID-based connection identification (#3594)** (a70a6d0)
- **[ISSUE #3576]🚀Add new constructor for service task with Arc support✨ (#3577)** (4c68d6b)
- **[ISSUE #3563]Add missing semicolon in default HA service client initialization (#3564)** (afe1b5e)
- **[ISSUE ##3548]🔨Add codeql.yml action (#3549)** (f8a281c)

### Fixes
- **[ISSUE #3733]🐛Fix commit log append offset calculation in HA client (#3734)** (4734044)
- **[ISSUE #3446]Fix typo in documentation for pull_offset_of_op parameter in default_transactional_message_service (#3630)** (556e51a)
- **Potential fix for code scanning alert no. 3: Workflow does not contain permissions (#3628)** (37e9eaf)
- **Potential fix for code scanning alert no. 5: Workflow does not contain permissions (#3627)** (d4b2468)
- **Potential fix for code scanning alert no. 6: Workflow does not contain permissions (#3626)** (7284acc)
- **Potential fix for code scanning alert no. 2: Workflow does not contain permissions (#3625)** (f0b37c5)
- **Potential fix for code scanning alert no. 7: Workflow does not contain permissions (#3624)** (6f6042f)
- **[ISSUE #3622]Fix broken unimplemented! macro in recover_initialize_service function (#3623)** (291d160)
- **[ISSUE #3591]♻️Fix typo in flush manager module name: defalut -> default (#3592)** (34d336f)
- **[ISSUE #3580]⚡️Fix GroupTransferService memory leaks and improve request processing reliability (#3581)** (d0e1454)

### Backend
- **Bump syn from 2.0.105 to 2.0.106 (#3777)** (257f413)
- **Bump proc-macro2 from 1.0.97 to 1.0.101 (#3774)** (114eae8)
- **Bump thiserror from 2.0.14 to 2.0.15 (#3773)** (73e629d)
- **[ISSUE #3770]♻️Refactor ConsumerFilterManager to accept message_store_config and update related initialization (#3771)** (f0a53d9)
- **[ISSUE #3768]📝Refactor broker-simple.toml to reorganize Broker Identity section (#3769)** (f72fd18)
- **[ISSUE #3761]🧩Consolidate tolerant enum parsing for BrokerRole & MessageRequestMode (helper, docs, tests, policy) (#3762)** (f181caf)
- **[ISSUE #3759]✨Accept mixed-case BrokerRole variants (AsyncMaster/SyncMaster/Slave) & tests added (#3760)** (757b4e8)
- **[ISSUE #3757]📝broker.toml sample updated to list mixed-case MessageRequestMode variants (#3758)** (e42815a)
- **[ISSUE #3395]Replace manual impls with derive(RequestHeaderCodec) in GetConsumeStatsRequestHeader (#3751)** (1facad9)
- **[ISSUE #3394]Replace manual impls with derive(RequestHeaderCodec) in GetAllTopicConfigResponseHeader (#3752)** (f865496)
- **[ISSUE ##2934]Replace manual impls with derive(RequestHeaderCodec) in AddWritePermOfBrokerResponseHeader (#3753)** (35c22d6)
- **[ISSUE ##3396]Replace manual impls with derive(RequestHeaderCodec) in GetConsumerListByGroupResponseHeader (#3750)** (f17b6ab)
- **[ISSUE #3397]Replace manual impls with derive(RequestHeaderCodec) in GetMaxOffsetRequestHeader (#3740)** (7abd033)
- **[ISSUE #3399]Replace manual impls in GetMinOffsetRequestHeader with RequestHeaderCodec (#3739)** (4cc95cc)
- **[ISSUE #3736]♻️Refactor GeneralHAClient to use enum for HA client management (#3737)** (5111c64)
- **[ISSUE #3731]🚀Async commit log append pipeline & HA reader integration (#3732)** (3c09185)
- **[ISSUE #3729]📝Update main loop comment for clarity in HA client connection handling (#3730)** (cef85d0)
- **[ISSUE #2801]Replace init_logger() with init_logger_with_level() (#3728)** (a85759d)
- **[ISSUE #3726]♻️ HA client concurrent reader/writer split, atomic timestamp arcs & error channel propagation (#3727)** (06bf48d)
- **[ISSUE #3724]♻️HA client state machine extraction & loop simplification (#3725)** (0b6efae)
- **[ISSUE #3393]Refactor ElectMasterResponseHeader with derive marco RequestHeaderCodec (#3723)** (2c134d0)
- **[ISSUE #3721]♻️Resilient topic route retrieval & decoding error handling in client (#3722)** (b00142e)
- **[ISSUE #3716]♻️Type-safe RocketMqVersion comparisons & accessor (rocketmq_version) across remoting, broker, namesrv, client (#3717)** (140bb06)
- **[ISSUE #3714]♻️Unify version management via CURRENT_VERSION and simplify RemotingCommand version init (#3715)** (ef9a124)
- **Bump syn from 2.0.104 to 2.0.105 (#3713)** (9892297)
- **[ISSUE #3709]♻️Narrow BrokerData equality to broker_name + broker_addrs (#3710)** (1724fe5)
- **Bump uuid from 1.17.0 to 1.18.0 (#3698)** (ba2ef99)
- **Bump anyhow from 1.0.98 to 1.0.99 (#3703)** (3857465)
- **Bump sysinfo from 0.36.1 to 0.37.0 (#3700)** (f15aa08)
- **Bump libc from 0.2.174 to 0.2.175 (#3701)** (78a5eca)
- **Bump proc-macro2 from 1.0.95 to 1.0.97 (#3702)** (bdd6662)
- **Bump thiserror from 2.0.12 to 2.0.14 (#3697)** (906e930)
- **Bump clap from 4.5.43 to 4.5.45 (#3704)** (7a6730e)
- **Bump reqwest from 0.12.22 to 0.12.23 (#3705)** (8c088d9)
- **Bump config from 0.15.13 to 0.15.14 (#3706)** (90202f2)
- **[ISSUE #3696]error[E0275]: overflow evaluating the requirement (#3707)** (2939003)
- **[ISSUE #3694]♻️Move service handle out of Inner and make HAClient::start idempotent (#3695)** (ae76217)
- **[ISSUE #3400]Refactor GetTopicConfigRequestHeader with derive marco RequestHeaderCodec (#3691)** (38b91e6)
- **[ISSUE #3692]Remove unnecessary #![feature(duration_constructors_lite)] (#3693)** (ec97aba)
- **[ISSUE #3675]♻️Refactor DefaultHAClient to use FramedRead and FramedWrite for improved stream handling and memory efficiency (#3690)** (dacce64)
- **[ISSUE #3688]Remove zerocopy and zerocopy-derive useless crate from rocketmq-store crate Cargo.toml (#3689)** (e7e7b79)
- **[ISSUE #3398]Refactor GetMetaDataResponseHeader with derive marco RequestHeaderCodec (#3686)** (75e0892)
- **[ISSUE #2840]Replace CommitLog#recover_abnormally println! with error! (#3687)** (fabcf8a)
- **Refactor DeleteTopicRequestHeader (#3685)** (d8b5198)
- **[ISSUE #3407]Refactor QueryConsumerOffsetRequestHeader with derive marco RequestHeaderCodec (#3674)** (ed45401)
- **[ISSUE #3404]Refactor NotifyConsumerIdsChangedRequestHeader with derive marco RequestHeaderCodec (#3681)** (8deb5f6)
- **[ISSUE #3403]Refactor LockBatchMqRequestHeader with derive marco RequestHeaderCodec (#3682)** (f7e2ace)
- **[ISSUE #3401]Refactor GetTopicStatsRequestHeader with derive marco RequestHeaderCodec (#3683)** (0913d63)
- **Bump bytemuck from 1.23.1 to 1.23.2 (#3684)** (56624bc)
- **Refactor CreateTopicRequestHeader (#3679)** (5ee4e0c)
- **Bump clap from 4.5.42 to 4.5.43 (#3678)** (447288c)
- **[ISSUE #2987] Remove ConsumeQueue#put_message_position_info #[inline] (#3676)** (ef561c8)
- **Bump tokio-util from 0.7.15 to 0.7.16 (#3673)** (df96167)
- **[ISSUE #3664]Refactor is_time_to_report_offset to remove async and improve performance (#3672)** (f3452a8)
- **[ISSUE #3389]Refactor GetConsumerConnectionListRequestHeader with derive marco RequestHeaderCodec (#3671)** (9b14650)
- **[ISSUE ##3663]Remove redundant license block from default_ha_service.rs (#3670)** (24eae97)
- **[ISSUE #3668]♻️Restructure DefaultHAClient with Inner struct pattern for improved memory management (#3669)** (56d4944)
- **[ISSUE #3666]♻️Standardize HAClient trait start method signature to use mutable reference (#3667)** (cfb2cce)
- **[ISSUE #3388]Refactor EndTransactionRequestHeader with derive marco RequestHeaderCodec (#3665)** (f5474fd)
- **[ISSUE #3402]Refactor HeartbeatRequestHeader with derive marco RequestHeaderCodec (#3661)** (1ac4001)
- **[ISSUE #3387]Refactor RpcRequestHeader with derive marco RequestHeaderCodec (#3662)** (2c46bc0)
- **[ISSUE #3410]Refactor QueryTopicsByConsumerRequestHeader with derive marco RequestHeaderCodec (#3660)** (888a296)
- **Bump serde_json from 1.0.141 to 1.0.142 (#3659)** (a8107b6)
- **Bump tokio from 1.47.0 to 1.47.1 (#3658)** (df1309a)
- **[ISSUE #3656]✨Implement notification mechanism and synchronization improvements for GroupTransferService (#3657)** (513e079)
- **[ISSUE #3655]Update README.md (#3654)** (3537c1c)
- **[ISSUE #3650]Removed unnecessary code from DefaultHAService (#3651)** (df2d625)
- **[ISSUE #3648]✨Implement atomic transfer notifications and HA service integration (#3649)** (3d7c63e)
- **[ISSUE #3263]Removed unnecessary code from EndTransactionProcessor (#3645)** (7d1d417)
- **[ISSUE #3262]Removed unnecessary code from ChangeInvisibleTimeProcessor (#3646)** (46a7e19)
- **[ISSUE #2703]Removed unnecessary code from PullRequestHoldService (#3647)** (278df9f)
- **[ISSUE #3643]Removed unnecessary code from DefaultHAService (#3644)** (ab27a24)
- **[ISSUE #3641]🔨Remove codeql CI (#3642)** (88a8666)
- **Optimize ReadSocketService and WriteSocketService to use OwnedReadHalf and OwnedWriteHalf for improved socket handling (#3632) (#3640)** (964cb14)
- **Bump clap from 4.5.41 to 4.5.42 (#3639)** (9284e48)
- **[ISSUE #3304]Remove CommitLog#handle_disk_flush_and_ha useless code (#3638)** (7358817)
- **[ISSUE #3345]⚡️Remove TransactionalMessageCheckListenerInner useless code (#3637)** (1422556)
- **[ISSUE #3635]🔨Update automerge.yml to trigger on pull_request instead of pull_request_target (#3636)** (f14551c)
- **[ISSUE #3409]♻️Refactor QueryTopicConsumeByWhoRequestHeader with derive marco RequestHeaderCodec (#3634)** (c5522c1)
- **[ISSUE #3413]♻️Refactor UnregisterClientRequestHeader with derive marco RequestHeaderCodec (#3633)** (7f916ef)
- **[ISSUE #3620]♻️Enhance DefaultHAConnection with specialized I/O and OffsetDecoder (#3631)** (2fcc4a9)
- **Bump tokio from 1.46.1 to 1.47.0 (#3629)** (1ea85b7)
- **changes typo on line 467 \rocketmq-rust\rocketmq-broker\src\broker_runtime.rs (#3621)** (0794844)
- **[ISSUE #3618]♻️Replace unsafe pointer operations with safe memory management in DefaultHAClient (#3619)** (6f4fb1b)
- **[ISSUE #3613]♻️Convert HA service is_slave_ok method from sync to async (#3617)** (1849e08)
- **[ISSUE #3613]♻️Clean up AckMessageProcessor - remove unused variables and lint suppressions (#3614)** (8e6a783)
- **Bump criterion from 0.6.0 to 0.7.0 (#3612)** (39fcf95)
- **[ISSUE #3610]♻️Convert HA system shutdown methods from sync to async (#3611)** (9021abe)
- **[ISSUE #3608]⚡️Improve HA connection management and state notification (#3609)** (ccbda24)
- **[ISSUE #3606]⚡️Improve HA connection error handling and socket initialization robustness (#3607)** (3ce1f69)
- **[ISSUE #3604]⚡️Improve HA connection shutdown mechanism and complete message processing (#3605)** (8c535a6)
- **[ISSUE #3602]♻️Improve HA client interface with proper type safety and optionality (#3603)** (be0403b)
- **[ISSUE #3600]⚡️Improve HAService interface consistency and placeholder implementations (#3601)** (f119ff9)
- **[ISSUE #3598]⚡️Standardize connection count type to AtomicU32 across HA services (#3599)** (aab8c61)
- **Bump rand from 0.9.1 to 0.9.2 (#3597)** (d41773a)
- **[ISSUE #3595]⚡️Integrate HAConnectionId throughout HA connection system and optimize storage (#3596)** (81025bb)
- **[ISSUE #3589]♻️Simplify HA client initialization and remove unnecessary ArcMut wrappers (#3590)** (7e01905)
- **[ISSUE #3587]⚡️Standardize HA client access with concrete types and comprehensive documentation (#3588)** (11e4098)
- **[ISSUE #3584]⚡️Implement HA connection management with concrete connection list functionality (#3585)** (2480fad)
- **[ISSUE #3582]⚡️Complete GroupTransferService request lifecycle with customer notification and timeout handling (#3583)** (aaab157)
- **[ISSUE #3578]♻️HA Service Architecture Enhancement and Type Consistency Improvements✨ (#3579)** (8394cfa)
- **[ISSUE #3574]🚀Major HA Service Architecture Enhancement and Group Commit Implementation (#3575)** (d9f211b)
- **[ISSUE #3572]⚡️Optimize handle_disk_flush_and_ha error handling and status resolution (#3573)** (dda4a39)
- **[ISSUE #3569]Code Cleanup: Remove Commented Dead Code in CommitLog (#3570)** (4329be4)
- **Bump serde_json from 1.0.140 to 1.0.141 (#3568)** (7b55db1)
- **Bump sysinfo from 0.36.0 to 0.36.1 (#3567)** (673f0e4)
- **Bump memmap2 from 0.9.5 to 0.9.7 (#3566)** (6a8062a)
- **Bump crc32fast from 1.4.2 to 1.5.0 (#3565)** (6a28576)
- **[ISSUE #3544]Major Refactoring: HA Connection Architecture and Lifecycle Management (#3562)** (db836fa)
- **Bump sysinfo from 0.35.2 to 0.36.0 (#3561)** (894b5b9)
- **Bump clap from 4.5.40 to 4.5.41 (#3560)** (0b51c95)
- **Bump config from 0.15.12 to 0.15.13 (#3559)** (d0a7055)
- **Bump config from 0.15.11 to 0.15.12 (#3558)** (9b5e7a5)
- **Remove commented-out code in PullMessageRequestHeader, PullMessageResponseHeader and QueryMessageRequestHeader (#3557)** (b4ddbc6)
- **Refactor ReplyMessageRequestHeader with derive marco RequestHeaderCodec #3411 (#3556)** (18ece28)
- **[ISSUE #3554]♻️Refactor HAConnectionStateNotificationRequest complete method to be asynchronous and update imports (#3555)** (1d608b9)
- **Bump tokio from 1.46.0 to 1.46.1 (#3553)** (eece54d)
- **[ISSUE #3551]♻️Refactor name server invocation logic to handle empty name server lists more gracefully (#3552)** (d0b73ca)
- **Bump tokio from 1.45.1 to 1.46.0 (#3547)** (cb6cc4f)
- **Bump reqwest from 0.12.21 to 0.12.22 (#3546)** (fb911ea)

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