mxsm

Apache EventMesh PMC,Committer & Apache RocketMQ active contributor & RocketMQ-Rust owner

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 @dependabot[bot] in #3448
  • Bump windows from 0.61.1 to 0.61.2 by @dependabot[bot] in #3449
  • [ISSUE #3450]⚡️Implement From trait for LanguageCode to enhance type conversions✨ by @mxsm in #3451
  • [ISSUE #3452]🚀Add ConsumerAttr struct and builder for metrics tracking by @mxsm in #3453
  • [ISSUE #3454]🚀Add BrokerMetricsConstant struct and organized metrics for RocketMQ monitoring✨ by @mxsm in #3455
  • [ISSUE #3456]🚀Add PopMetricsConstant struct and organized metrics for RocketMQ Pop operations✨ by @mxsm in #3457
  • Bump windows from 0.61.2 to 0.61.3 by @dependabot[bot] in #3458
  • Bump syn from 2.0.102 to 2.0.103 by @dependabot[bot] in #3460
  • Bump libc from 0.2.172 to 0.2.173 by @dependabot[bot] in #3459
  • [ISSUE #3461]🚀Refactor shutdown methods to be asynchronous for improved performance and responsiveness✨ by @mxsm in #3462
  • [ISSUE #3464]📝Update comments in get_message_result.rs for clarity on offsets and buffer size by @mxsm in #3465
  • [ISSUE #3466]♻️Refactor offset handling in default_transactional_message_service.rs for improved clarity and performance🚀 by @mxsm in #3467
  • [ISSUE #3463]Remove unused queue_id generation code from default_transactional_message_check_listener.rs by @saishreyakumar in #3468
  • [ISSUE #3470]🚀Enhance HAConnectionState with additional methods for state management and transitions✨ by @mxsm in #3471
  • [ISSUE #3472]🚀Add FlowMonitor for tracking data transfer metrics and flow control management✨ by @mxsm in #3473
  • Bump lz4_flex from 0.11.3 to 0.11.4 by @dependabot[bot] in #3474
  • [ISSUE #3408]Refactor QueryMessageRequestHeader with derive marco RequestHeaderCodec by @donghao526 in #3476
  • [ISSUE #3475]🚀Implement DefaultHAConnection✨ by @mxsm in #3477
  • Bump libc from 0.2.173 to 0.2.174 by @dependabot[bot] in #3478
  • [ISSUE #3405]♻️Refactor PullMessageRequestHeader with derive marco RequestHeaderCodec by @donghao526 in #3479
  • [ISSUE #3406]♻️Refactor PullMessageResponseHeader with derive marco RequestHeaderCodec by @donghao526 in #3480
  • [ISSUE #3481]⚡️Enhancement DefaultHAConnection to simplify socket stream handling and improve readability✨ by @mxsm in #3482
  • Bump lz4_flex from 0.11.4 to 0.11.5 by @dependabot[bot] in #3484
  • [ISSUE #3390] ♻️Refactor GetConsumerListByGroupRequestHeader with derive marco RequestHeaderCodec by @donghao526 in #3483
  • [ISSUE #3485]⚡️Optimize DefaultHAConnection WriteSocketService to improve data transfer handling and buffer management by @mxsm in #3488
  • Bump syn from 2.0.103 to 2.0.104 by @dependabot[bot] in #3490
  • [ISSUE #3491]🚀Add group_commit_request module to log_file for enhanced commit handling✨ by @mxsm in #3492
  • [ISSUE #3493]🚀Refactor GroupCommitRequest: Extract common initialization logic✨ by @mxsm in #3494
  • [ISSUE #3496]🚀Implement HAServiceWrapper and AutoSwitchHAService for enhanced High Availability✨ by @mxsm in #3498
  • [ISSUE #3412]♻️Refactor UnlockBatchMqRequestHeader with derive marco RequestHeaderCodec by @578223592 in #3497
  • [ISSUE #3499]🚀Implement DefaultHAClient for comprehensive master-slave replication✨ by @mxsm in #3500
  • [ISSUE #3501]🚀Implement GeneralHAService and controller mode for unified HA architecture✨ by @mxsm in #3502
  • [ISSUE #3503]🚀Implement General HA components and complete AutoSwitch HA implementation✨ by @mxsm in #3504
  • [ISSUE #3505]🚀Implement comprehensive HA service infrastructure with GroupTransfer and ConnectionState services✨ by @mxsm in #3506
  • [ISSUE #3510]🚀Implement Comprehensive High Availability (HA) Subsystem Architecture with Enhanced Service Infrastructure✨ by @mxsm in #3511
  • [ISSUE #3512]🚀Async High Availability (HA) Service Architecture Enhancement ✨ by @mxsm in #3513
  • [ISSUE #3515]🐛Memory Safety Issue in DefaultHAClient master_address Field Implementation by @mxsm in #3516
  • [ISSUE #3517]⚡️Memory Management Fix for AtomicPtr-based Address Fields in HA Client by @mxsm in #3518
  • [ISSUE #3519]⚡️Async socket handling migration using tokio-util for HA connection layer by @mxsm in #3520
  • [ISSUE #3521]⚡️Increase buffer capacity for Framed connection to 1 MB in new Connection implementation by @mxsm in #3522
  • [ISSUE #3523]⚡️Increase buffer size to 8 KB in Connection implementation by @mxsm in #3524
  • [ISSUE #3525]⚡️Trait-based architecture for HA connections with unified error handling by @mxsm in #3526
  • [ISSUE #3527]⚡️Delegation pattern implementation with error handling for HA connections by @mxsm in #3528
  • [ISSUE #3529]♻️Refactor HAConnection start method to use match statement for cleaner connection handling by @mxsm in #3530
  • [ISSUE #3532]🚀Implement missing methods in DefaultHAConnection for state management and data transfer by @mxsm in #3533
  • [ISSUE #3534]🚀Implement connection handling in HAConnection methods with error logging by @mxsm in #3535
  • [ISSUE #3536]🐛Update heartbeat size in DefaultHAConnection to use dynamic size instead of a fixed value by @mxsm in #3537
  • [ISSUE #3538]⚡️Connection count management and resource cleanup delegation by @mxsm in #3539
  • [ISSUE #3540]⚡️Shutdown safety and state management improvements for HA services by @mxsm in #3541
  • [ISSUE #3531] Define constant for framed connection capacity in HAConnection start method by @yahayaohinoyi in #3542
  • [ISSUE #3487] Optimize connection buffer handling to use split method by @yahayaohinoyi in #3543
  • Bump reqwest from 0.12.20 to 0.12.21 by @dependabot[bot] in #3545
  • Bump reqwest from 0.12.21 to 0.12.22 by @dependabot[bot] in #3546
  • Bump tokio from 1.45.1 to 1.46.0 by @dependabot[bot] in #3547
  • [ISSUE #3551]♻️Refactor name server invocation logic to handle empty name server lists more gracefully by @mxsm in #3552
  • [ISSUE #3548]🔨Add codeql.yml action by @mxsm in #3549
  • Bump tokio from 1.46.0 to 1.46.1 by @mxsm in #3553
  • [ISSUE #3554]♻️Refactor HAConnectionStateNotificationRequest complete method to be asynchronous and update imports by @mxsm in #3555
  • Refactor ReplyMessageRequestHeader with derive marco RequestHeaderCodec #3411 by @donghao526 in #3556
  • Remove commented-out code in PullMessageRequestHeader, PullMessageResponseHeader and QueryMessageRequestHeader by @donghao526 in #3557
  • Bump config from 0.15.11 to 0.15.12 by @dependabot[bot] in #3558
  • Bump config from 0.15.12 to 0.15.13 by @dependabot[bot] in #3559
  • Bump clap from 4.5.40 to 4.5.41 by @dependabot[bot] in #3560
  • Bump sysinfo from 0.35.2 to 0.36.0 by @dependabot[bot] in #3561
  • [ISSUE #3544]Major Refactoring: HA Connection Architecture and Lifecycle Management by @mxsm in #3562
  • [ISSUE #3563]Add missing semicolon in default HA service client initialization by @mxsm in #3564
  • Bump crc32fast from 1.4.2 to 1.5.0 by @dependabot[bot] in #3565
  • Bump memmap2 from 0.9.5 to 0.9.7 by @dependabot[bot] in #3566
  • Bump sysinfo from 0.36.0 to 0.36.1 by @dependabot[bot] in #3567
  • Bump serde_json from 1.0.140 to 1.0.141 by @dependabot[bot] in #3568
  • [ISSUE #3569]Code Cleanup: Remove Commented Dead Code in CommitLog by @mxsm in #3570
  • [ISSUE #3572]⚡️Optimize handle_disk_flush_and_ha error handling and status resolution by @mxsm in #3573
  • [ISSUE #3574]🚀Major HA Service Architecture Enhancement and Group Commit Implementation by @mxsm in #3575
  • [ISSUE #3576]🚀Add new constructor for service task with Arc support✨ by @mxsm in #3577
  • [ISSUE #3578]♻️HA Service Architecture Enhancement and Type Consistency Improvements✨ by @mxsm in #3579
  • [ISSUE #3580]⚡️Fix GroupTransferService memory leaks and improve request processing reliability by @mxsm in #3581
  • [ISSUE #3582]⚡️Complete GroupTransferService request lifecycle with customer notification and timeout handling by @mxsm in #3583
  • [ISSUE #3584]⚡️Implement HA connection management with concrete connection list functionality by @mxsm in #3585
  • [ISSUE #3587]⚡️Standardize HA client access with concrete types and comprehensive documentation by @mxsm in #3588
  • [ISSUE #3589]♻️Simplify HA client initialization and remove unnecessary ArcMut wrappers by @mxsm in #3590
  • [ISSUE #3591]♻️Fix typo in flush manager module name: defalut -> default by @mxsm in #3592
  • [ISSUE #3593]⚡️Add HAConnectionId struct with UUID-based connection identification by @mxsm in #3594
  • [ISSUE #3595]⚡️Integrate HAConnectionId throughout HA connection system and optimize storage by @mxsm in #3596
  • Bump rand from 0.9.1 to 0.9.2 by @dependabot[bot] in #3597
  • [ISSUE #3598]⚡️Standardize connection count type to AtomicU32 across HA services by @mxsm in #3599
  • [ISSUE #3600]⚡️Improve HAService interface consistency and placeholder implementations by @mxsm in #3601
  • [ISSUE #3602]♻️Improve HA client interface with proper type safety and optionality by @mxsm in #3603
  • [ISSUE #3604]⚡️Improve HA connection shutdown mechanism and complete message processing by @mxsm in #3605
  • [ISSUE #3606]⚡️Improve HA connection error handling and socket initialization robustness by @mxsm in #3607
  • [ISSUE #3608]⚡️Improve HA connection management and state notification by @mxsm in #3609
  • [ISSUE #3610]♻️Convert HA system shutdown methods from sync to async by @mxsm in #3611
  • Bump criterion from 0.6.0 to 0.7.0 by @dependabot[bot] in #3612
  • [ISSUE #3613]♻️Clean up AckMessageProcessor - remove unused variables and lint suppressions by @mxsm in #3614
  • [ISSUE #3616]♻️Convert HA service is_slave_ok method from sync to async by @mxsm in #3617
  • [ISSUE #3618]♻️Replace unsafe pointer operations with safe memory management in DefaultHAClient by @mxsm in #3619
  • changes typo on line 467 \rocketmq-rust\rocketmq-broker\src\broker_ru… by @Sudharsan-T in #3621
  • [ISSUE #3622]Fix broken unimplemented! macro in recover_initialize_service function by @Sudharsan-T in #3623
  • Potential fix for code scanning alert no. 7: Workflow does not contain permissions by @mxsm in #3624
  • Potential fix for code scanning alert no. 2: Workflow does not contain permissions by @mxsm in #3625
  • Potential fix for code scanning alert no. 6: Workflow does not contain permissions by @mxsm in #3626
  • Potential fix for code scanning alert no. 5: Workflow does not contain permissions by @mxsm in #3627
  • Potential fix for code scanning alert no. 3: Workflow does not contain permissions by @mxsm in #3628
  • Bump tokio from 1.46.1 to 1.47.0 by @dependabot[bot] in #3629
  • [ISSUE #3446]Fix typo in documentation for pull_offset_of_op parameter in default_transactional_message_service by @SuriyaPrakash-J in #3630
  • [ISSUE #3620]♻️Enhance DefaultHAConnection with specialized I/O and OffsetDecoder by @mxsm in #3631
  • [ISSUE #3413]♻️Refactor UnregisterClientRequestHeader with derive marco RequestHeaderCodec by @donghao526 in #3633
  • [ISSUE #3409]♻️Refactor QueryTopicConsumeByWhoRequestHeader with derive marco RequestHeaderCodec by @donghao526 in #3634
  • [ISSUE #3635]🔨Update automerge.yml to trigger on pull_request instead of pull_request_target by @mxsm in #3636
  • [ISSUE #3345]⚡️Remove TransactionalMessageCheckListenerInner useless code by @ButterflyEffect1991 in #3637
  • [ISSUE #3304]Remove CommitLog#handle_disk_flush_and_ha useless code by @ButterflyEffect1991 in #3638
  • Bump clap from 4.5.41 to 4.5.42 by @dependabot[bot] in #3639
  • Optimize ReadSocketService and WriteSocketService (#3632) by @ritoban23 in #3640
  • [ISSUE #3641]🔨Remove codeql CI by @mxsm in #3642
  • [ISSUE #3643]Removed unnecessary code from DefaultHAService by @satnam72 in #3644
  • Removed unnecessary code from PullRequestHoldService by @satnam72 in #3647
  • Removed unnecessary code from ChangeInvisibleTimeProcessor by @satnam72 in #3646
  • Removed unnecessary code from EndTransactionProcessor by @satnam72 in #3645
  • [ISSUE #3648]✨Implement atomic transfer notifications and HA service integration by @mxsm in #3649
  • Removed unnecessary code from DefaultHAService by @satnam72 in #3651
  • Add links to contributor and license icons by @operagxsasha in #3652
  • docs: (contributing) by @operagxsasha in #3654
  • [ISSUE #3656]✨Implement notification mechanism and synchronization improvements for GroupTransferService by @mxsm in #3657
  • Bump tokio from 1.47.0 to 1.47.1 by @dependabot[bot] in #3658
  • Bump serde_json from 1.0.141 to 1.0.142 by @dependabot[bot] in #3659
  • Refactor QueryTopicsByConsumerRequestHeader with derive macro RequestHeaderCodec by @satnam72 in #3660
  • [ISSUE #3387]Refactor RpcRequestHeader with derive marco RequestHeaderCodec by @satnam72 in #3662
  • [ISSUE #3402]Refactor HeartbeatRequestHeader with derive marco RequestHeaderCodec by @satnam72 in #3661
  • Refactor EndTransactionRequestHeader with derive marco RequestHeaderCodec by @satnam72 in #3665
  • [ISSUE #3666]♻️Standardize HAClient trait start method signature to use mutable reference by @mxsm in #3667
  • [ISSUE #3668]♻️Restructure DefaultHAClient with Inner struct pattern for improved memory management by @mxsm in #3669
  • [ISSUE ##3663]Remove redundant license block from default_ha_service.rs by @dhvll in #3670
  • [ISSUE #3389]Refactor GetConsumerConnectionListRequestHeader with derive marco RequestHeaderCodec by @satnam72 in #3671
  • [ISSUE #3664]Refactor is_time_to_report_offset to remove async and improve performance by @satnam72 in #3672
  • Bump tokio-util from 0.7.15 to 0.7.16 by @dependabot[bot] in #3673
  • [ISSUE #2903]Enhancement⚡️ Add #[inline] for store_path_config_helper methods by @donghao526 in #3677
  • [ISSUE #2987] Remove ConsumeQueue#put_message_position_info #[inline] by @donghao526 in #3676
  • Bump clap from 4.5.42 to 4.5.43 by @dependabot[bot] in #3678
  • Refactor CreateTopicRequestHeader by @satnam72 in #3679
  • Add #[inline] to methods by @satnam72 in #3680
  • Bump bytemuck from 1.23.1 to 1.23.2 by @dependabot[bot] in #3684
  • Refactor GetTopicStatsRequestHeader by @satnam72 in #3683
  • Refactor LockBatchMqRequestHeader by @satnam72 in #3682
  • Refactor NotifyConsumerIdsChangedRequestHeader by @satnam72 in #3681
  • [ISSUE #3407]Refactor QueryConsumerOffsetRequestHeader with derive marco RequestHeaderCodec by @dhvll in #3674
  • Refactor DeleteTopicRequestHeader by @satnam72 in #3685
  • Replace println! with error! by @satnam72 in #3687
  • [ISSUE #3398]Refactor GetMetaDataResponseHeader with derive marco RequestHeaderCodec by @zeina1i in #3686
  • [ISSUE #3688]Remove zerocopy and zerocopy-derive useless crate from rocketmq-store crate Cargo.toml by @satnam72 in #3689
  • [ISSUE #3675]♻️Refactor DefaultHAClient to use FramedRead and FramedWrite for improved stream handling and memory efficiency by @mxsm in #3690
  • Remove duration_constructors_lite feature by @satnam72 in #3693
  • Refactor GetTopicConfigRequestHeader by @satnam72 in #3691
  • [ISSUE #3694]♻️Move service handle out of Inner and make HAClient::start idempotent by @mxsm in #3695
  • [ISSUE #3696]error[E0275]: overflow evaluating the requirement by @mxsm in #3707
  • Bump config from 0.15.13 to 0.15.14 by @dependabot[bot] in #3706
  • Bump reqwest from 0.12.22 to 0.12.23 by @dependabot[bot] in #3705
  • Bump clap from 4.5.43 to 4.5.45 by @dependabot[bot] in #3704
  • Bump thiserror from 2.0.12 to 2.0.14 by @dependabot[bot] in #3697
  • Bump proc-macro2 from 1.0.95 to 1.0.97 by @dependabot[bot] in #3702
  • Bump libc from 0.2.174 to 0.2.175 by @dependabot[bot] in #3701
  • Bump sysinfo from 0.36.1 to 0.37.0 by @dependabot[bot] in #3700
  • Bump anyhow from 1.0.98 to 1.0.99 by @dependabot[bot] in #3703
  • Bump uuid from 1.17.0 to 1.18.0 by @dependabot[bot] in #3698
  • [ISSUE #3709]♻️Narrow BrokerData equality to broker_name + broker_addrs by @mxsm in #3710
  • Refactor MessageExt to add inline attribute by @satnam72 in #3711
  • Bump syn from 2.0.104 to 2.0.105 by @dependabot[bot] in #3713
  • Refactor RemotingSysResponseCode method with inline attribute by @satnam72 in #3712
  • [ISSUE #3714]♻️Unify version management via CURRENT_VERSION and simplify RemotingCommand version init by @mxsm in #3715
  • [ISSUE #3716]♻️Type-safe RocketMqVersion comparisons & accessor (rocketmq_version) across remoting, broker, namesrv, client by @mxsm in #3717
  • [ISSUE #3719]♻️Generalize EnvUtils API & add typed accessors (default/i32/bool) with expanded tests by @mxsm in #3720
  • [ISSUE #3721]♻️Resilient topic route retrieval & decoding error handling in client by @mxsm in #3722
  • Refactor ElectMasterResponseHeader by @satnam72 in #3723
  • [ISSUE #3724]♻️HA client state machine extraction & loop simplification by @mxsm in #3725
  • [ISSUE #3726]♻️ HA client concurrent reader/writer split, atomic timestamp arcs & error channel propagation by @mxsm in #3727
  • Replace init_logger() with init_logger_with_level() by @satnam72 in #3728
  • [ISSUE #3729]📝Update main loop comment for clarity in HA client connection handling by @mxsm in #3730
  • [ISSUE #3731]🚀Async commit log append pipeline & HA reader integration by @mxsm in #3732
  • [ISSUE #3733]🐛Fix commit log append offset calculation in HA client by @mxsm in #3734
  • [ISSUE #3736]♻️Refactor GeneralHAClient to use enum for HA client management by @mxsm in #3737
  • refactor: Replace manual impls in GetMinOffsetRequestHeader with RequestHeaderCodec by @4ddx in #3739
  • [ISSUE #3741]📝Add configuration files for nameserver settings in RocketMQ by @mxsm in #3742
  • [ISSUE #3743]📝Add configuration files for broker settings in RocketMQ by @mxsm in #3744
  • refactor: Replace manual impls in GetMaxOffsetRequestHeader with RequestHeaderCodec by @4ddx in #3740
  • [ISSUE #3745]📝Update broker configuration with enhanced settings and new parameters by @mxsm in #3746
  • [ISSUE #3747]♻️Introduce common error module & strict config parsing across broker/namesrv by @mxsm in #3748
  • refactor: replace manual impls with derive(RequestHeaderCodec) in GetConsumerListByGroupResponseHeader by @4ddx in #3750
  • refactor: replace manual impls with derive(RequestHeaderCodec) in AddWritePermOfBrokerResponseHeader by @4ddx in #3753
  • refactor: replace manual impls with derive(RequestHeaderCodec) in GetAllTopicConfigResponseHeader by @4ddx in #3752
  • refactor: replace manual impls with derive(RequestHeaderCodec) in GetConsumeStatsRequestHeader by @4ddx in #3751
  • [ISSUE #3755]✨Accept mixed-case variants for MessageRequestMode (“Pull”/”Pop”) & add tests by @mxsm in #3756
  • [ISSUE #3757]📝broker.toml sample updated to list mixed-case MessageRequestMode variants by @mxsm in #3758
  • [ISSUE #3759]✨Accept mixed-case BrokerRole variants (AsyncMaster/SyncMaster/Slave) & tests added by @mxsm in #3760
  • [ISSUE #3761]🧩Consolidate tolerant enum parsing for BrokerRole & MessageRequestMode (helper, docs, tests, policy) by @mxsm in #3762
  • [ISSUE #3763]📝Add comprehensive storeConfig section to broker.toml sample (review & cross-doc sync) by @mxsm in #3764
  • Add #[inline] for MessageBatch struct method by @dhvll in #3754
  • [ISSUE #3766]📝Add initial broker-simple.toml configuration file with core settings by @mxsm in #3767
  • [ISSUE #3768]📝Refactor broker-simple.toml to reorganize Broker Identity section by @mxsm in #3769
  • [ISSUE #3770]♻️Refactor ConsumerFilterManager to accept message_store_config and update related initialization by @mxsm in #3771
  • Bump thiserror from 2.0.14 to 2.0.15 by @dependabot[bot] in #3773
  • Bump proc-macro2 from 1.0.97 to 1.0.101 by @dependabot[bot] in #3774
  • Bump syn from 2.0.105 to 2.0.106 by @dependabot[bot] in #3777
  • feat(epoch): introduce EpochEntryCache with basic accessors and tests by @4ddx in #3772
  • [ISSUE #3775]♻️Refactor ConsumerOffsetManager to support generic message store and enhance offset management functionality by @mxsm in #3776

New Contributors

Full Changelog: v0.5.0...v0.6.0

You may also enjoy

RocketMQ Rust Release 🔖v0.5.0

🔊Announcement: RocketMQ Rust 🔖v0.5.0 has been officially released. For more detailed changes, please refer to the following documentation.

RocketMQ Rust Release 🔖v0.4.0

🔊Announcement: RocketMQ Rust 🔖v0.4.0 has been officially released. For more detailed changes, please refer to the following documentation.

RocketMQ Rust Release 🔖v0.3.0

🔊Announcement: RocketMQ Rust 🔖v0.3.0 has been officially released. For more detailed changes, please refer to the following documentation.

RocketMQ Rust Release 🔖v0.2.0

🔊Announcement: RocketMQ Rust 🔖v0.2.0 has been officially released. For more detailed changes, please refer to the following documentation.