RocketMQ Rust Release 🔖v0.5.0

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
• [ISSUE #2699]🚀Implement PopLongPollingService#notifyMessageArrivingWithRetryTopic method acording to Java by @mxsm in #2700
• [ISSUE #2701]Optimize PopLongPollingService#polling method by @mxsm in #2702
• Bump once_cell from 1.21.0 to 1.21.1 by @dependabot in #2705
• Bump tokio from 1.44.0 to 1.44.1 by @dependabot in #2706
• Bump tokio-util from 0.7.13 to 0.7.14 by @dependabot in #2707
• [ISSUE #2708]🐛Fix Ack append message topic not correct by @mxsm in #2709
• Bump tempfile from 3.18.0 to 3.19.0 by @dependabot in #2711
• Bump uuid from 1.15.1 to 1.16.0 by @dependabot in #2712
• [ISSUE #2710]♻️Refactor ReputMessageService by @mxsm in #2713
• [ISSUE #2714]🚀NotifyMessageArrivingListener add pop message arriving notification by @mxsm in #2715
• [ISSUE #2718]Fix PopRequest#complete return value not correct by @mxsm in #2719
• [ISSUE #2720]Add comments for PopMessageProcessor by @mxsm in #2721
• [ISSUE #2725]♻️Refactor MessageStore trait by @mxsm in #2726
• [ISSUE #2723]🚀Stepped message delay implementation🍻 by @mxsm in #2728
• [ISSUE #2729]🚀Refactor LocalFileMessageStore-1🍻 by @mxsm in #2730
• [ISSUE #2731]🚀Add HAError by @mxsm in #2738
• [ISSUE #2732]🚀Add HAConnectionState by @mxsm in #2739
• [ISSUE #2734]🚀Add WaitNotifyObject by @mxsm in #2740
• [ISSUE #2733]🚀Add HAConnectionStateNotificationRequest by @mxsm in #2741
• [ISSUE #2735]🚀Add HAClient by @mxsm in #2742
• [ISSUE #2736]🚀Add HAConnection by @mxsm in #2743
• [ISSUE #2737]🚀Add HAService by @mxsm in #2744
• [ISSUE #2745]🚀Add GeneralHAService to wrapper DefaultHAService by @mxsm in #2746
• [ISSUE #2747]♻️Refactor LocalFileMessageStore start method🍻 by @mxsm in #2748
• [ISSUE #2749]♻️Refactor LocalFileMessageStore shutdown method🍻 by @mxsm in #2750
• Bump windows from 0.60.0 to 0.61.1 by @dependabot in #2751
• Bump reqwest from 0.12.14 to 0.12.15 by @dependabot in #2752
• [ISSUE #2753]🚀Implement LocalFileMessageStore destroy method🍻 by @mxsm in #2754
• Bump tempfile from 3.19.0 to 3.19.1 by @dependabot in #2756
• [ISSUE #2755]♻️Refactor LocalFileMessage put message by @mxsm in #2757
• [ISSUE #2758]♻️Refactor LocalFileMessage put batch messages by @mxsm in #2759
• [ISSUE #2760]♻️Refactor LocalFileMessageStore get message by @mxsm in #2761
• [ISSUE #2762]♻️Refactor LocalFileMessageStore get queue offset by @mxsm in #2763
• [ISSUE #2764]♻️Refactor LocalFileMessageStore look message by offset by @mxsm in #2765
• [ISSUE #2766]🚀Add TimerMetrics struct by @mxsm in #2767
• [ISSUE #2768]🚀Implement LocalFileMessageStore get runtime info method by @mxsm in #2769
• [ISSUE #2770]🚀Implement earlist message time by @mxsm in #2771
• [ISSUE #2772]🚀Implement LocalFileMessageStore get commit log data by @mxsm in #2773
• [ISSUE #2774]🚀Implement append_to_commit_log and execute_delete_files_manually methods by @mxsm in #2775
• [ISSUE #2776]🚀Refactor LocalFileMessageStore methods🍻 by @mxsm in #2777
• [ISSUE #2778]🚀Replace DefaultMessageStore with LocalFileMessageStore🍻 by @mxsm in #2779
• [ISSUE #2780] fix typo. borker -> broker by @tofulim in #2781
• [ISSUE #2782]🔨Update automerge.yml by @SpaceXCN in #2783
• [ISSUE #2784]🚀Rename ReferenceResourceImpl to ReferenceResourceCounter🍻 by @mxsm in #2785
• [ISSUE #2786]🚀Refactor ReferenceResourceCounter🍻 by @mxsm in #2787
• [ISSUE #2791]🚀Optimize client_metadata cargo clippy – -D warnings🍻 by @mxsm in #2792
• [ISSUE #2788]🚀Optimize DefaultMappedFile ReferenceResourceCounter hold and release🍻 by @mxsm in #2789
• [ISSUE #2790]🚀Implement ScheduleMessageService#load method🍻 by @mxsm in #2793
• [ISSUE #2795]🐛Fix ScheduleMessageService start eq not correct🍻 by @mxsm in #2796
• [ISSUE #2727]🚀Stepped message delay implementation-2🍻 by @mxsm in #2797
• [ISSUE #2799]🚀Implement LocalFileMessageStore#find_consume_queue🍻 by @mxsm in #2800
• [ISSUE #2803]📝Add code comments for ScheduleMessageService 🍻 by @mxsm in #2804
• [ISSUE #2805]📝Replace MessageStore methods &str parameters with &CheetahString🍻 by @mxsm in #2806
• [ISSUE #2808]⚡️Replace PutResultProcess attributes String with CheetahString🍻 by @mxsm in #2809
• [ISSUE #2810]⚡️BrokerRuntimeInner add some unchecked methods for Option attributes🍻 by @mxsm in #2811
• [ISSUE #2807]🚀Implement ScheduleMessageService#message_time_up method🍻 by @mxsm in #2812
• [ISSUE #2817]📝Add Architecture pitcture for doc🍻 by @mxsm in #2818
• [ISSUE #2819]📝Add Architecture zh doc by @mxsm in #2821
• [ISSUE #2820]📝Add Architecture en doc by @mxsm in #2822
• [ISSUE #2823]🚀Add BrokerAttachedPlugin trait by @mxsm in #2824
• [ISSUE #2814]🚀Implement BrokerRuntime#changeSpecialServiceStatus method by @mxsm in #2825
• [ISSUE #2815]🚀Implement BrokerRuntime changeScheduleServiceStatus method by @mxsm in #2826
• [ISSUE #2828]🚀Implement AckMessageProcessor#set_pop_revive_service_st… by @mxsm in #2829
• [ISSUE #2816]🚀Implement BrokerRuntime changeTransactionCheckServiceSt… by @mxsm in #2827
• [ISSUE #2802]🚀Broker start ScheduleMessageService by @mxsm in #2830
• [ISSUE #2831]🐛Broker start ScheduleMessageService’s method not correct by @mxsm in #2832
• [ISSUE #2833]🐛Fix MessageStoreConfig flush_delay_offset_interval value is zero by @mxsm in #2834
• [ISSUE #2835]🚀Implement LocalFileMessageStore#get_message_store_config method by @mxsm in #2837
• [ISSUE #2836]🚀Implement LocalFileMessageStore#get_consume_queue method by @mxsm in #2838
• [ISSUE #2841]🚀Implement TimerMessageStore#get_enqueue_behind_millis method💫 by @mxsm in #2842
• [ISSUE #2843]🚀Add build.rs for rocketmq-broker crate by @mxsm in #2844
• [ISSUE #2846]⚡️Optimize PutMessageHook#execute_before_put_message method signature by @mxsm in #2847
• [ISSUE #2848]⚡️Optimize PutMessageHook#execute_before_put_message by @mxsm in #2849
• [ISSUE #2850]⚡️Optimize HookUtils some methods by @mxsm in #2851
• [ISSUE #2845]🚀Add ScheduleMessageHook struct by @mxsm in #2852
• [ISSUE #2853]🚀Add build.rs for rocketmq-namesrv crate by @mxsm in #2854
• [ISSUE #2855]🚀Add ScheduleMessageHook to MessageStore💫 by @mxsm in #2856
• [ISSUE #2857]♻️Refactor PutResultProcess by @mxsm in #2858
• [ISSUE #2859]🚀Implement PutResultProcess#then_process method by @mxsm in #2860
• [ISSUE #2861]📝Add some commnets for HookUtils#transform_delay_level_message💫 by @mxsm in #2862
• Bump clap from 4.5.32 to 4.5.33 by @dependabot in #2864
• [ISSUE #2865]🚀Add StringUtils#parse_delay_level method by @mxsm in #2866
• [ISSUE #2863]🚀Implement handle Timing message in CommitLog#check_message_and_return_size method by @mxsm in #2867
• Bump once_cell from 1.21.1 to 1.21.2 by @dependabot in #2868
• Bump sysinfo from 0.33.1 to 0.34.0 by @dependabot in #2869
• Bump clap from 4.5.33 to 4.5.34 by @dependabot in #2870
• [ISSUE #2872]🐛Fix Rebuild Properties not correct by @mxsm in #2873
• [ISSUE #2875]⚡️Optimize RouteInfoManager#register_broker by @mxsm in #2877
• [ISSUE #2876]⚡️Add #[inline] to ArcMut methods by @hkkzzxzmdwhkzz in #2879
• [ISSUE #2880]📝Add doc for IndexHeader 💫 by @mxsm in #2881
• Bump sysinfo from 0.34.0 to 0.34.1 by @dependabot in #2882
• Bump once_cell from 1.21.2 to 1.21.3 by @dependabot in #2883
• [ISSUE #2884]♻️Refactor IndexHeader by @mxsm in #2885
• [ISSUE #2886]⚡️Remove some #[inline] from IndexFile methods by @mxsm in #2887
• [ISSUE #2888]⚡️Optimize JavaStringHasher by @mxsm in #2889
• [ISSUE #2890]🐛Key hash code abs may with panic by @mxsm in #2891
• [ISSUE #2892]⚡️Replace IndexHeader wite data method append_message_offset_length by @mxsm in #2893
• [ISSUE #2871]🐛Reput Message to build index error by @mxsm in #2894
• [ISSUE #2895]🚀MappedFile add get_slice method by @mxsm in #2896
• [ISSUE #2897]♻️Refactor IndexFile#select_phy_offset method by @mxsm in #2898
• [ISSUE #2899]⚡️Optimize util_all#time_millis_to_human_string method by @mxsm in #2900
• [ISSUE #2901]🧪Add test case for time_millis_to_human_string3 by @mxsm in #2902
• [ISSUE #2904]📝Add Namesrv config 💫 by @mxsm in #2905
• [ISSUE #2907]🚀Implement IndexService shutdown💫 by @mxsm in #2908
• [ISSUE #2909]🚀Optimize IndexService load💫 by @mxsm in #2910
• [ISSUE #2911]⚡️Remove IndexService some methods #[inline]💫 by @mxsm in #2912
• [ISSUE #2913]⚡️Optimize get_total_size method💫 by @mxsm in #2914
• [ISSUE #2915]🚀Complete the IndexService delete_expired_file method💫 by @mxsm in #2916
• [ISSUE #2918]🚀Optimize IndexService query_offset💫 by @mxsm in #2919
• [ISSUE #2920]🚀Optimize IndexService build_index and others methods💫 by @mxsm in #2921
• [ISSUE #2922]🚀Optimize Name server config file parse💫 by @mxsm in #2923
• [ISSUE #2926]🐛Fix EnvUtils::put_property test case error💫 by @mxsm in #2927
• [ISSUE #2924]📝Update rocketmq namesrv start command help print💫 by @mxsm in #2925
• [ISSUE #2928]⚡️Optimize namesrv parse config error print by @mxsm in #2929
• [ISSUE #2930]⚡️Optimize DefaultRequestProcessor#put_kv_config method by @mxsm in #2931
• [ISSUE #2935]⚡️Optimize RouteInfoManager#delete_topic method💫 by @mxsm in #2936
• [ISSUE #2937]⚡️Add the PopReviveService log print decision💫 by @mxsm in #2938
• [ISSUE #2939]✨Implement LocalFileMessageStore#get_broker_stats_manager💫 by @mxsm in #2940
• [ISSUE #2941]🚀Implement CommitLog#pickup_store_timestamp by @mxsm in #2942
• [ISSUE #2944]🚀Implement LocalFileMessageStore#remain_transient_store_buffer_numbs by @mxsm in #2945
• [ISSUE #2948]🐛Fix can’t delete topic from rocketmq dashboard by @mxsm in #2949
• [ISSUE #2951]🚀Implement ConsumeQueueStore#find_consume_queue_map method by @mxsm in #2952
• [ISSUE #2953]🚀Implement ConsumeQueueStore#get_total_size method by @mxsm in #2954
• Bump clap from 4.5.34 to 4.5.35 by @dependabot in #2955
• Bump sysinfo from 0.34.1 to 0.34.2 by @dependabot in #2956
• [ISSUE #2958]⚡️Optimize DefaultMappedFile#get_file_from_offset by @mxsm in #2959
• [ISSUE #2960]⚡️Remove DefaultMappedFile method’s #[inline] by @mxsm in #2961
• [ISSUE #2962]🚀Add get_bytes_readable_checked method and remove some useless methods by @mxsm in #2963
• [ISSUE #2964]🚀Add ReferredIterator trait by @mxsm in #2965
• [ISSUE #2966]🚀Add FileQueueLifeCycle trait by @mxsm in #2967
• [ISSUE #2968]🚀Add ConsumeQueue trait by @mxsm in #2969
• [ISSUE #2970]🚀Add ConsumeQueueStore trait by @mxsm in #2971
• [ISSUE #2972]⚡️Remove queue FileQueueLifeCycle by @mxsm in #2973
• [ISSUE #2974]🚀 Add local_file_consume_queue_store_refactor by @mxsm in #2975
• [ISSUE #2976]⚡️Optimize ConsumeQueue new by @mxsm in #2977
• [ISSUE #2978]✨Refactor ConsumeQueueStore#load_consume_queues💫 by @mxsm in #2979
• Bump flate2 from 1.1.0 to 1.1.1 by @dependabot in #2981
• [ISSUE #2980]♻️Refactor ConsumeQueueStore💫 by @mxsm in #2982
• [ISSUE #2983]🚀Support CQType::RocksDBCQ create ConsumeQueue by @mxsm in #2984
• [ISSUE #2985]♻️Refactor TopicAttributes💫 by @mxsm in #2986
• [ISSUE #2988]♻️Refactor ConsumeQueue💫 by @mxsm in #2989
• Bump openssl from 0.10.70 to 0.10.72 by @dependabot in #2990
• [ISSUE #2991]⚡️Optimize ConsumeQueue#put_message_position_info💫 by @mxsm in #2992
• [ISSUE #2993]♻️Refactor MappedFileQueue💫 by @mxsm in #2994
• [ISSUE #2996]🚀Implement MappedFileQueue#check_self method💫 by @mxsm in #2997
• [ISSUE #2998]🚀Optimize MappedFileQueue#do_load💫 by @mxsm in #2999
• [ISSUE #3000]🚀Optimize util_all#char_to_byte performance💫 by @mxsm in #3001
• [ISSUE #3002]🚀Add file appender for log💫 by @mxsm in #3003
• [ISSUE #3004]🚀Add rocketmq-rust-site submodule💫 by @mxsm in #3005
• Revert “[ISSUE #3004]🚀Add rocketmq-rust-site submodule💫” by @mxsm in #3007
• [ISSUE #3008]🐛Fix file appender can not working💫 by @mxsm in #3009
• [ISSUE #3010]📝Add doc for get_message_request_mode_path method💫 by @mxsm in #3011
• [ISSUE #3012]📝Add doc for QueryAssignmentProcessor💫 by @mxsm in #3013
• [ISSUE #3014]⚡️Simplify TopicRouteInfoManager#get_topic_subscribe_info💫 by @mxsm in #3015
• [ISSUE #3016]⚡️Optimize QueryAssignmentProcessor#allocate_for_pop💫 by @mxsm in #3017
• Bump tokio from 1.44.1 to 1.44.2 by @dependabot in #3019
• [ISSUE #3021]📝Add comments for PopMessageProcessor#_process_request by @mxsm in #3022
• [ISSUE #3023]⚡️Optimize ConsumerOffsetManager#query_offset logic by @mxsm in #3024
• [ISSUE #3025]⚡️Optimize QueueLockManager logic by @mxsm in #3026
• [ISSUE #3027]⚡️Optimize SelectMappedBufferResult#get_bytes method by @mxsm in #3028
• [ISSUE #3029]⚡️Optimize GetMessageResult#add_message and add_message_inner by @mxsm in #3030
• [ISSUE #3031]⚡️Replace CompositeCodec BytesMut with Bytes by @mxsm in #3032
• [ISSUE #3033]🚀Connection add send_bytes and send_slice methods by @mxsm in #3034
• [ISSUE #3035]🚀DefaultMappedFile add file mapped bytes by @mxsm in #3036
• [ISSUE #3037]⚡️Optimize SelectMappedBufferResult by @mxsm in #3038
• [ISSUE #3039]🚀Implement PopMessageProcessor zero copy transform by @mxsm in #3040
• [ISSUE #3041]⚡️Implement Pull message zero copy transform💫 by @mxsm in #3042
• Bump hostname from 0.4.0 to 0.4.1 by @dependabot in #3043
• [ISSUE #3044]⚡️Implement GetMessageResult default trait by @mxsm in #3045
• [ISSUE #3046]🚀Implement ConsumeQueue#iterate_from_with_count method by @mxsm in #3047
• [ISSUE #3048]🚀Implement· RemotingCommand#header_encode method by @mxsm in #3049
• [ISSUE #3050]🐛PopMessageProcessor zero copy transform header encode incorrect by @mxsm in #3051
• [ISSUE #3052]🐛PullMessageProcessor zero copy transfer header encode incorrect by @mxsm in #3053
• [ISSUE #3055]⚡️Optimize ReputMessageServiceInner#do_reput method by @mxsm in #3056
• [ISSUE #3058]🚀Add ChannelEventListener trait for Remoting by @mxsm in #3059
• [ISSUE #3060]🚀Add ChannelEventListener for ConnectionListener by @mxsm in #3061
• [ISSUE #3063]⚡️Optimize ConsumerManager broker_stats_manager attribute by @mxsm in #3064
• [ISSUE #3065]🚀Implement ConsumerManager#findChannel by @mxsm in #3066
• [ISSUE #3067]⚡️Optimize ConsumerManager#register_consumer_ext method by @mxsm in #3068
• [ISSUE #3069]🚀Implement ConsumerManager#unregisterConsumer method by @mxsm in #3070
• [ISSUE #3071]🚀Implement ConsumerManager#register_consumer_without_sub method by @mxsm in #3072
• [ISSUE #3073]🚀Implement ConsumerManager scan_not_active_channel and remove_expire_consumer_group_info method by @mxsm in #3074
• Bump crossbeam-channel from 0.5.14 to 0.5.15 by @dependabot in #3076
• [ISSUE #3077]⚡️Optimize ClientManageProcessor return type by @mxsm in #3078
• [ISSUE #3075]🚀ClientManageProcessor supports UnregisterClient(request code:35) by @mxsm in #3079
• [ISSUE #3080]🚀Add ClientHousekeepingService by @mxsm in #3081
• [ISSUE #3082]🚀Implement ConsumerManager#do_channel_close_event method by @mxsm in #3083
• [ISSUE #3084]🚀Add ProducerGroupEvent enum by @mxsm in #3085
• [ISSUE #3086]🚀Add ProducerChangeListener trait by @mxsm in #3087
• [ISSUE #3089]⚡️ProducerManager add some attrutes by @mxsm in #3090
• [ISSUE #3091]♻️Refactor Channel💫 by @mxsm in #3092
• Bump clap from 4.5.35 to 4.5.36 by @dependabot in #3093
• [ISSUE #3094]⚡️Optimize Channel and ChannelInner💫 by @mxsm in #3095
• [ISSUE #3096]🚀pub use anyhow::Result as RocketMQResult💫 by @mxsm in #3098
• [ISSUE #3099]🚀Add TokioEvent struct 💫 by @mxsm in #3100
• [ISSUE #3102]🚀Add client_housekeeping_service for broker💫 by @mxsm in #3103
• [ISSUE #3101]🚀Add BrokerHousekeepingService for name server crate 💫 by @mxsm in #3104
• [ISSUE #3105]🚀Add rocketmq-error crate💫 by @mxsm in #3106
• [ISSUE #3107]🔨Add rocketmq-error crate for package script💫 by @mxsm in #3108
• [ISSUE #3097]♻️Rocketmq error refactor by @mxsm in #3109
• [ISSUE #3110]⚡️Optimize Config file parse by @mxsm in #3111
• Bump anyhow from 1.0.97 to 1.0.98 by @dependabot in #3112
• [ISSUE #3113]🚀Add ProducerInfo struct by @mxsm in #3115
• [ISSUE #3114]🚀Add ProducerTableInfo struct by @mxsm in #3116
• [ISSUE #3117]🚀Implement ProducerManager get_producer_table and call_producer_change_listener by @mxsm in #3118
• [ISSUE #3119] Implement ProducerManager#scan_not_active_channel by @mxsm in #3121
• [ISSUE #3120]🚀Implement ProducerManager#do_channel_close_event by @mxsm in #3122
• [ISSUE #3124]🐛Broker not config file started fail by @mxsm in #3125
• [ISSUE #3057]🚀Add ChannelEventListener implement for Remoting by @mxsm in #3126
• [ISSUE #3127]⚡️Set PopReviveService ShouldRunPopRevive on new by @mxsm in #3128
• [ISSUE #3129]🐛Fix ExtraInfoUtil split not correct by @mxsm in #3130
• Bump libc from 0.2.171 to 0.2.172 by @dependabot in #3132
• [ISSUE #3131]⚡️Optimize ExtraInfoUtil by @mxsm in #3133
• [ISSUE #3134]⚡️Optimize AckMessageProcessor#append_ack logic handle by @mxsm in #3135
• [ISSUE #3136]📝Add comments for ConsumerOffsetManager attribute by @mxsm in #3137
• [ISSUE #3138]⚡️Optimize AckMessageProcessor#append_ack code and add comments by @mxsm in #3139
• Bump proc-macro2 from 1.0.94 to 1.0.95 by @dependabot in #3141
• Bump rand from 0.9.0 to 0.9.1 by @dependabot in #3142
• Bump clap from 4.5.36 to 4.5.37 by @dependabot in #3143
• [ISSUE #3140]⚡️Implement PopReviveService#revive_msg_from_ck method by @mxsm in #3144
• [ISSUE #3145]⚡️Optimize EscapeBridge#get_message_async method return type by @mxsm in #3146
• [ISSUE #3148]🚀Implement PopReviveService#mockCkForAck by @mxsm in #3149
• [ISSUE #3150]🚀Implement PopReviveService get_revive_behind_millis and get_revive_behind_messages by @mxsm in #3151
• [ISSUE #3152]🚀Add comments for PopBufferMergeService by @mxsm in #3153
• [ISSUE #3154]🚀Implement NotificationProcessor by @mxsm in #3157
• Bump tokio-util from 0.7.14 to 0.7.15 by @dependabot in #3160
• [ISSUE #3165]🚀Optimize cargo clippy – -D warnings by @mxsm in #3175
• Bump bytemuck from 1.22.0 to 1.23.0 by @dependabot in #3173
• Bump chrono from 0.4.40 to 0.4.41 by @dependabot in #3174
• Bump local-ip-address from 0.6.3 to 0.6.4 by @dependabot in #3164
• Bump syn from 2.0.100 to 2.0.101 by @dependabot in #3171
• Bump tabled from 0.18.0 to 0.19.0 by @dependabot in #3163
• [ISSUE #3166]📝Update README.md by @mxsm in #3176
• [ISSUE #3177]🚀Implement NotificationProcessor start and shutdown by @mxsm in #3178
• [ISSUE #3179]⚡️Optimize ScheduleMessageService by @mxsm in #3180
• [ISSUE #3181]⚡️Remove BrokerRuntime useless code by @mxsm in #3182
• [ISSUE #3183]🚀Implement LocalFileMessageStore get_dispatcher_list and add_dispatcher methods by @mxsm in #3184
• Bump sysinfo from 0.34.2 to 0.35.0 by @dependabot in #3186
• [ISSUE #3187]🚀Implement CommitLogDispatcherCalcBitMap by @mxsm in #3189
• [ISSUE #3190]🚀BrokerRutime message store add CommitLogDispatcherCalcBitMap by @mxsm in #3191
• [ISSUE #3192]🚀Replace MessageStoreConfig and ServerConfig with Arc in BrokerRuntime by @mxsm in #3193
• [ISSUE #3194]🚀Optimize Borker code by @mxsm in #3195
• [ISSUE #3196]🚀Implement ConsumeQueueStore recover_concurrently by @mxsm in #3197
• [ISSUE #3198]🚀Implement ConsumeQueueStore#check_self by @mxsm in #3199
• [ISSUE #3200]🚀Add Slot struct for Timer message by @mxsm in #3201
• [ISSUE #3202]🚀Optimize SendMessageProcessor code by @mxsm in #3203
• [ISSUE #3204]🚀Optimize ValidateTopicResult add take_remark method by @mxsm in #3205
• [ISSUE #3204]⚡️Remove use lazy_static::lazy_static in TopicAttributes by @mxsm in #3207
• [ISSUE #3208]⚡️Optimize TopicValidator by @ButterflyEffect1991 in #3209
• [ISSUE #3018]⚡️Add #[inline] for PermName’s methods by @shadowsoy in #3210
• [ISSUE #3211]⚡️Optimize TopicConfigManager#init method by @mxsm in #3212
• [ISSUE #2704]⚡️Optimize broker_bootstrap_server log init by @578223592 in #3213
• [ISSUE #2932]♻️Refactor WipeWritePermOfBrokerResponseHeader with derive marco RequestHeaderCodec by @rust-learn-now in #3214
• [ISSUE #3215]⚡️Implement BrokerRuntime#register_increment_broker_data by @mxsm in #3217
• [ISSUE #2933]♻️Refactor AddWritePermOfBrokerRequestHeader with derive marco RequestHeaderCodec by @flydream-ylgw in #3218
• [ISSUE #3216]⚡️Implement BrokerRuntime#register_increment_broker_data by @mxsm in #3219
• [ISSUE #3222]⚡️Add rocketmq-rust logo by @mxsm in #3223
• [ISSUE #3224]⚡️Add rocketmq-rust logo by @mxsm in #3225
• [ISSUE #3221]📝Update README.md by @mxsm in #3226
• [ISSUE #3227]♻️Refactor SendMessageProcessor handle_put_message_result by @mxsm in #3228
• [ISSUE #3229]🐛Fix Broker can not startup due to ConsumeQueueStore#check_self by @mxsm in #3230
• [ISSUE #3231]🚀Implement ConsumeQueue#check_self by @mxsm in #3232
• [ISSUE #3233]⚡️Optimize LocalFileMessageStore put_message_hook_list attribute by @mxsm in #3234
• [ISSUE #3236]Optimize Code Format by @578223592 in #3235
• [ISSUE #3237]⚡️Optimize SendMessageProcessor send_message by @mxsm in #3238
• Bump tokio from 1.44.2 to 1.45.0 by @dependabot in #3239
• [ISSUE #3241]📝Update READM.md by @mxsm in #3242
• [ISSUE #3243]📝Update README.md by @mxsm in #3244
• [ISSUE #2794]Improve KVConfigManager perfermance with DashHashp by @578223592 in #3240
• [ISSUE #3246]⚡️Optimize MessageExtEncoder performance by @mxsm in #3247
• [ISSUE #3248]📝Add DeepWiki badge by @mxsm in #3249
• [ISSUE #3250]⚡️Replace MessageIdSupplier Box with Arc by @mxsm in #3251
• [ISSUE #3252]🐛Fix DefaultMappedFile Dangling Reference issue by @mxsm in #3253
• [ISSUE #3254]⚡️Optimize ArcMut by @mxsm in #3255
• [ISSUE #3256]⚡️Optimize PutMessageThreadLocal performance by @mxsm in #3257
• [ISSUE #3258]⚡️Optimize TopicQueueLock by @mxsm in #3259
• [ISSUE #3260]📝Remove Associate Milestone action by @mxsm in #3261
• [ISSUE #3264]🚀RequestCode enum add more request code by @mxsm in #3265
• [ISSUE #3267]♻️Refactor PutMessageHook trait by @mxsm in #3268
• [ISSUE #3269]⚡️Optimize use of unstable library feature duration_constructors_lite by @mxsm in #3273
• Bump clap from 4.5.37 to 4.5.38 by @dependabot in #3270
• Bump tempfile from 3.19.1 to 3.20.0 by @dependabot in #3272
• Bump sysinfo from 0.35.0 to 0.35.1 by @dependabot in #3271
• [Feature🚀] Implement NotificationProcessor acording to Java code by @578223592 in #3245
• [Doc📝] Documentation Related ：Update Feature list in rocketmq-broker README.md by @578223592 in #3275
• [ISSUE #3279]📝Documentation Related ：Update Feature list in rocketmq-broker README.md by @578223592 in #3276
• [ISSUE #3280]⚡️Fix cargo clippy – -D warnings error by @mxsm in #3281

New Contributors

• @kamlesh0928 made their first contribution in #2590
• @Brijeshthummar02 made their first contribution in #2605
• @tofulim made their first contribution in #2781
• @hkkzzxzmdwhkzz made their first contribution in #2879
• @578223592 made their first contribution in #3213

Full Changelog: v0.4.0...v0.5.0