Release Notes - Apache RocketMQ - Version 5.3.0

Download the 5.3.0 release

• Source: rocketmq-all-5.3.0-source-release.zip [PGP] [SHA512]
• Binary: rocketmq-all-5.3.0-bin-release.zip [PGP] [SHA512] :::

Below is a summary of the issues addressed in the 5.3.0 release of RocketMQ. For full documentation of the release, a guide to get started, please refer to Quick Start.

Feature

• [ISSUE #7560][RIP-68] Support RocketMQ ACL 2.0 by @dingshuangxi888 in https://github.com/apache/rocketmq/pull/7725

Improvement

• [ISSUE #7831] Make rat-check successful by @caigy in https://github.com/apache/rocketmq/pull/7832
• [ISSUE #7821] Add notifyLast flag for PopLongPollingService by @drpmma in https://github.com/apache/rocketmq/pull/7835
• [ISSUE #7815] Use createChannelAsync for async invoke rpc by @drpmma in https://github.com/apache/rocketmq/pull/7816
• [ISSUE #7840] Update the version in the README.md document to 5.2.0 by @mxsm in https://github.com/apache/rocketmq/pull/7841
• Add statistics for the production of transaction messages. by @kingkh1995 in https://github.com/apache/rocketmq/pull/7766
• [ISSUE #7868] Use entrySet to close channel by @ChineseTony in https://github.com/apache/rocketmq/pull/7869
• [ISSUE #7845] Simplify the AbstractSendMessageProcessor#buildMsgContext code using Optional by @mxsm in https://github.com/apache/rocketmq/pull/7846
• [ISSUE #7875] Add constructor for ProxyTopicRouteData by @drpmma in https://github.com/apache/rocketmq/pull/7876
• [ISSUE #7881] Add parameter configuration explanations for jRaft controller by @RongtongJin in https://github.com/apache/rocketmq/pull/7882
• fix document typo by @zjko in https://github.com/apache/rocketmq/pull/7721
• [ISSUE #7907] Revise the description of transaction messages in Rocke… by @Gezi-lzq in https://github.com/apache/rocketmq/pull/7908
• [ISSUE #7904] Use string builder to concat string by @ChineseTony in https://github.com/apache/rocketmq/pull/7905
• [ISSUE #7926] Delete the unnecessary 'else' statement by @oopooa in https://github.com/apache/rocketmq/pull/7920
• [ISSUE #7923] Exclude the master that are currently down. by @zhuyuemufeng in https://github.com/apache/rocketmq/pull/7925
• [ISSUE #7932] Rectify the modifier order in namesrv by @oopooa in https://github.com/apache/rocketmq/pull/7921
• Fix some ambiguous logs by @caizhaomin1 in https://github.com/apache/rocketmq/pull/7934
• [ISSUE #7929] Add some request codes to the permission verification for the admin role by @RongtongJin in https://github.com/apache/rocketmq/pull/7930
• [ISSUE #7945] Make HAProxyMessageForwarder Scalable by @dingshuangxi888 in https://github.com/apache/rocketmq/pull/7946
• Fix notification integration test in pop consume mode by @drpmma in https://github.com/apache/rocketmq/pull/7947
• [ISSUE #7943] Add bazel config for auth module and fix bazel test by @dingshuangxi888 in https://github.com/apache/rocketmq/pull/7944
• [ISSUE #7955] Don't set default auth metadata provider by @dingshuangxi888 in https://github.com/apache/rocketmq/pull/7956
• [ISSUE #7974] Add repeatedly read same offset log to find unexpected situations by @lizhimins in https://github.com/apache/rocketmq/pull/7975
• [ISSUE #7961] Use BoundaryType in binarySearchInCQByTime by @Koado in https://github.com/apache/rocketmq/pull/7968
• Consume request count threshold log fix by @iamgd67 in https://github.com/apache/rocketmq/pull/7969
• [ISSUE #7970] remove unnecessary type cast by @ChineseTony in https://github.com/apache/rocketmq/pull/7971
• [ISSUE #7983] Use java optional by @ChineseTony in https://github.com/apache/rocketmq/pull/7984
• [ISSUE #7988] Refector client trace by @drpmma in https://github.com/apache/rocketmq/pull/7989
• [ISSUE #7963] Check consumer group existence in updateConsumerOffset by @redlsz in https://github.com/apache/rocketmq/pull/7964
• [ISSUE #7988] Set enableTrace default to false by @drpmma in https://github.com/apache/rocketmq/pull/8015
• [ISSUE #8020] Fix document typo by @hakusai22 in https://github.com/apache/rocketmq/pull/8021
• [ISSUE #8032] Set checkDupInfo value from config by @LittleBoy18 in https://github.com/apache/rocketmq/pull/8033
• [ISSUE #6398] Remove duplicate code in TopicPublishInfo by @syshenyao in https://github.com/apache/rocketmq/pull/8034
• [ISSUE #8023] Add expression filtering capability to the pullBlockIfNotFound method of pull consumer by @RongtongJin in https://github.com/apache/rocketmq/pull/8024
• [ISSUE #8044] Add Override annotation for AllocateMappedFileService#run by @mxsm in https://github.com/apache/rocketmq/pull/8045
• build: fix workflow and skip failed test for auth module on mac by @HScarb in https://github.com/apache/rocketmq/pull/8068
• [ISSUE #8100] Expose print audit log function by @dingshuangxi888 in https://github.com/apache/rocketmq/pull/8101
• [ISSUE #8105] Fix typo about udpate user by @zhiliatom in https://github.com/apache/rocketmq/pull/8106
• [ISSUE #5923] Fix tiered store README.md error about Configuration by @yuz10 in https://github.com/apache/rocketmq/pull/8110
• [ISSUE #8092] Fixed non-idempotent test by @kaiyaok2 in https://github.com/apache/rocketmq/pull/8093
• [ISSUE #8090] Optimize isSetEqual for DefaultLitePullConsumerImpl by @Willhow-Gao in https://github.com/apache/rocketmq/pull/8091
• [ISSUE #5838] Retry to send when broker returns SYSTEM_BUSY by @cserwen in https://github.com/apache/rocketmq/pull/5845
• [ISSUE #5923] Fix tiered store README.md error by @yuz10 in https://github.com/apache/rocketmq/pull/8115
• [ISSUE #8124] Avoid scheduled tasks exiting because of unknown exceptions by @colin719 in https://github.com/apache/rocketmq/pull/8121
• [ISSUE #8079] Add unit test for MQClientAPIExtTest by @drpmma in https://github.com/apache/rocketmq/pull/8080
• [ISSUE #8118] Remove redundant mod in client by @miles-ton in https://github.com/apache/rocketmq/pull/8119
• [ISSUE #8136] Replace with createProcessQueue and remove createProce… by @miles-ton in https://github.com/apache/rocketmq/pull/8139
• [ISSUE #8145] Optimize some code style in client module by @Willhow-Gao in https://github.com/apache/rocketmq/pull/8146
• [ISSUE #8148] Fix variable typo by @oopooa in https://github.com/apache/rocketmq/pull/8149
• [ISSUE #8155] Fix doc typo by @oopooa in https://github.com/apache/rocketmq/pull/8157
• [ISSUE #8142] Show time of create topic and subScriptionGroup by @superdev42 in https://github.com/apache/rocketmq/pull/8143
• [ISSUE #8164] Log more accurate for the MQClientInstance#doRebalance by @miles-ton in https://github.com/apache/rocketmq/pull/8165
• [ISSUE #8162] Optimize the logging printout for the ConfigManager#loadBak method by @mxsm in https://github.com/apache/rocketmq/pull/8163
• [ISSUE #8129] Support topic reserved time in tiered storage by @yuz10 in https://github.com/apache/rocketmq/pull/8130
• [ISSUE #8166] Optimize make compression type configurable in producer clinet level by @humkum in https://github.com/apache/rocketmq/pull/8167
• [ISSUE #8182] Modify variable names to enhance readability #8182 by @Stephanie0002 in https://github.com/apache/rocketmq/pull/8183
• [ISSUE #6873] If dns resolve controller address exception will update controllerAddresses to null by @weihubeats in https://github.com/apache/rocketmq/pull/8180
• [ISSUE #8222] Fix spelling errors in comments by @yx9o in https://github.com/apache/rocketmq/pull/8224
• Revert "[ISSUE #7757] UseCompositeByteBufto prevent memory copy." by @yuz10 in https://github.com/apache/rocketmq/pull/8209
• [ISSUE #8053] Return SYSTEM_BUSY if PutMessageStatus is OS_PAGE_CACHE_BUSY by @biningo in https://github.com/apache/rocketmq/pull/8054
• [ISSUE #8211] Add two metrics rocketmq_topic_create_execution_time and rocketmq_consumer_group_create_execution_time by @Stephanie0002 in https://github.com/apache/rocketmq/pull/8212
• [ISSUE #8223] Add two metrics rocketmq_topic_number and rocketmq_consumer_group_number by @Stephanie0002 in https://github.com/apache/rocketmq/pull/8225
• [ISSUE #8235] Add @Override annotation for handleDiskFlush method by @mxsm in https://github.com/apache/rocketmq/pull/8236
• [ISSUE #8241] Remove duplicate code by @3424672656 in https://github.com/apache/rocketmq/pull/8242
• [ISSUE #8245] Fix typo in user_guide.md by @liuzc9 in https://github.com/apache/rocketmq/pull/8244
• [ISSUE #8197] Support fast filter message by tag in tiered storage by @lizhimins in https://github.com/apache/rocketmq/pull/8198
• [ISSUE #8269] Support pop consumption filter in long polling service by @lizhimins in https://github.com/apache/rocketmq/pull/8271
• [ISSUE #8265] Implement Batch Creation of Topics in RocketMQ Admin by @guyinyou in https://github.com/apache/rocketmq/pull/8267
• [ISSUE #8278] Fix fail test by @3424672656 in https://github.com/apache/rocketmq/pull/8279
• [ISSUE #8285] Add more test coverage for BrokerPreOnlineService by @yx9o in https://github.com/apache/rocketmq/pull/8286
• [ISSUE #8276] Merge duplicate code in DefaultMQProducer constructor by @yx9o in https://github.com/apache/rocketmq/pull/8277
• Restrict some actions to be triggered only in the official repository by @totalo in https://github.com/apache/rocketmq/pull/7695
• [ISSUE #7941] Increase annotation by @3424672656 in https://github.com/apache/rocketmq/pull/7959
• [ISSUE #8227] Repeated merging in the constructor by @yx9o in https://github.com/apache/rocketmq/pull/8228
• [ISSUE #8281] Optimize pop log level by @drpmma in https://github.com/apache/rocketmq/pull/8282
• [ISSUE #8293] Remove the redundant code from the MessageDecoder#encodeMessage method by @mxsm in https://github.com/apache/rocketmq/pull/8294
• [ISSUE #7466] Added fast failure in adminBrokerThreadPoolQueue (#7466) by @yp969803 in https://github.com/apache/rocketmq/pull/7798
• [ISSUE #8300] Add more test coverage for DefaultMQProducer by @yx9o in https://github.com/apache/rocketmq/pull/8301
• fix document typo in SlaveActingMasterMode.md by @maclong1989 in https://github.com/apache/rocketmq/pull/8315
• [ISSUE #8274] Optimize some codestyles and fix some warnings by @Mrhorse99 in https://github.com/apache/rocketmq/pull/8275
• [ISSUE #8291] Format proxy watermark output by @zhiliatom in https://github.com/apache/rocketmq/pull/8292
• [ISSUE #8324] Add more test coverage for DefaultMQProducerImpl by @yx9o in https://github.com/apache/rocketmq/pull/8325
• Revert "[ISSUE #7686] The bornTime is not set when using the popMessage API in cluster mode." by @drpmma in https://github.com/apache/rocketmq/pull/8331
• [ISSUE #8343] Add more test coverage for MQClientAPIImpl by @yx9o in https://github.com/apache/rocketmq/pull/8344
• [ISSUE #8336] Adjust the default value of ackMessageThreadPoolNums to 16 to prevent performance bottlenecks during high traffic by @RongtongJin in https://github.com/apache/rocketmq/pull/8337
• [ISSUE #8352] Fix CLIENT_REGISTER behavior in ConsumerManager#registerConsumer by @drpmma in https://github.com/apache/rocketmq/pull/8353
• [ISSUE #8358] Client does not send heartbeats to all Nameserve in clustered mode, resulting in frequent disconnections by @weihubeats in https://github.com/apache/rocketmq/pull/8359
• [ISSUE #8348] Allow custom fast-failure queues to be added in BrokerFastFailure by @RongtongJin in https://github.com/apache/rocketmq/pull/8347
• [ISSUE #8298] optimize some code format or style by @supervate in https://github.com/apache/rocketmq/pull/8299
• [ISSUE #8360] Add more test coverage for MQAdminImpl by @yx9o in https://github.com/apache/rocketmq/pull/8361

Bug

• [ISSUE #7833] Fix rpchook is still executed when remotingServer calls invoke by @guyinyou in https://github.com/apache/rocketmq/pull/7834
• [ISSUE #7851] Fix hashcode and equals methods of SubscriptionGroupConfig by @glcrazier in https://github.com/apache/rocketmq/pull/7852
• [ISSUE #7853] Fix the manualDeleteFileSeveralTimes count by @ChineseTony in https://github.com/apache/rocketmq/pull/7855
• [ISSUE #7871] Fix unboxing npe in SendMessageRequestHeader by @drpmma in https://github.com/apache/rocketmq/pull/7873
• [ISSUE #7902] Fix reput thread may quit by throwing error by @humkum in https://github.com/apache/rocketmq/pull/7903
• [ISSUE #7878] Fix tiered storage module some bugs and performance improvement by @lizhimins in https://github.com/apache/rocketmq/pull/7899
• [ISSUE #7914] Fix pop revive msg to retry topic may lose messages by @fujian-zfj in https://github.com/apache/rocketmq/pull/7915
• [ISSUE #7836] Fix flush_behind_bytes wrong in transientStorePoolEnable not enable by @leizhiyuan in https://github.com/apache/rocketmq/pull/7957
• [ISSUE #7951] Fix the full statsInfo error when read and write queues are inconsistent by @cserwen in https://github.com/apache/rocketmq/pull/7952
• [ISSUE #7878] Fix query message offset return wrong offset with boundary type by @lizhimins in https://github.com/apache/rocketmq/pull/7962
• [ISSUE #7872] Fix tiered storage query message async return different view each time by @AYue-94 in https://github.com/apache/rocketmq/pull/7874
• Add interface comment for query offset operation with boundary type by @lizhimins in https://github.com/apache/rocketmq/pull/7965
• [ISSUE #7966] Fix scheduled tasks exiting due to unknown exceptions by @cserwen in https://github.com/apache/rocketmq/pull/7967
• [ISSUE #7979] Fix timerWheel message metric by @3424672656 in https://github.com/apache/rocketmq/pull/7980
• [ISSUE #7958] Fix proxy always return the first broker in findOneBroker by @leizhiyuan in https://github.com/apache/rocketmq/pull/7960
• [ISSUE #7909] Fix send retry message permission check by @redlsz in https://github.com/apache/rocketmq/pull/7917
• [ISSUE #7848] Fix exception when pop messages with multiple LMQ indexes by @redlsz in https://github.com/apache/rocketmq/pull/7863
• [ISSUE #8095] Fix some flaky tests on Mac's workflow by @RongtongJin in https://github.com/apache/rocketmq/pull/8083
• [ISSUE #8096] Fix log placeholder by @HScarb in https://github.com/apache/rocketmq/pull/8097
• [ISSUE #8076] Fix correct min cq offset when delete tiered storage CommitLog by @lizhimins in https://github.com/apache/rocketmq/pull/8082
• [ISSUE #8098] Fix parsing delay message type from property by @redlsz in https://github.com/apache/rocketmq/pull/8099
• [ISSUE #8103] Fix SimpleSubscriptionData equal by @drpmma in https://github.com/apache/rocketmq/pull/8104
• [ISSUE #8108] Fix check MetadataProvider when enable acl2.0 by @zhiliatom in https://github.com/apache/rocketmq/pull/8109
• [ISSUE #8049] Fix tiered storage delete topic NPE in default metadata store by @bxfjb in https://github.com/apache/rocketmq/pull/8050
• [ISSUE #8046] Fix authentication context build for no extFields by @dingshuangxi888 in https://github.com/apache/rocketmq/pull/8102
• [ISSUE #8061] Fix npe in netty remoting client by @fujian-zfj in https://github.com/apache/rocketmq/pull/8064
• [ISSUE #8168] Fix retry send message when async produce already timeout by @humkum in https://github.com/apache/rocketmq/pull/8169
• [ISSUE #8230] Fix the acl for NotifyClientTerminationRequest because group can be null by @dingshuangxi888 in https://github.com/apache/rocketmq/pull/8231
• [ISSUE #8268] Fix pop orderly commitOffset when NO_MATCHED_MESSAGE by @drpmma in https://github.com/apache/rocketmq/pull/8270
• [ISSUE #8239] Fix the issue of potential message loss after a crash under synchronous disk flushing configuration. by @RongtongJin in https://github.com/apache/rocketmq/pull/8240

New Contributors

• @glcrazier made their first contribution in https://github.com/apache/rocketmq/pull/7852
• @ChineseTony made their first contribution in https://github.com/apache/rocketmq/pull/7869
• @zjko made their first contribution in https://github.com/apache/rocketmq/pull/7721
• @Gezi-lzq made their first contribution in https://github.com/apache/rocketmq/pull/7908
• @oopooa made their first contribution in https://github.com/apache/rocketmq/pull/7920
• @zhuyuemufeng made their first contribution in https://github.com/apache/rocketmq/pull/7925
• @caizhaomin1 made their first contribution in https://github.com/apache/rocketmq/pull/7934
• @3424672656 made their first contribution in https://github.com/apache/rocketmq/pull/7980
• @hakusai22 made their first contribution in https://github.com/apache/rocketmq/pull/8021
• @syshenyao made their first contribution in https://github.com/apache/rocketmq/pull/8034
• @kaiyaok2 made their first contribution in https://github.com/apache/rocketmq/pull/8093
• @Willhow-Gao made their first contribution in https://github.com/apache/rocketmq/pull/8091
• @colin719 made their first contribution in https://github.com/apache/rocketmq/pull/8121
• @superdev42 made their first contribution in https://github.com/apache/rocketmq/pull/8143
• @Stephanie0002 made their first contribution in https://github.com/apache/rocketmq/pull/8183
• @biningo made their first contribution in https://github.com/apache/rocketmq/pull/8054
• @liuzc9 made their first contribution in https://github.com/apache/rocketmq/pull/8244
• @Mrhorse99 made their first contribution in https://github.com/apache/rocketmq/pull/8275
• @supervate made their first contribution in https://github.com/apache/rocketmq/pull/8299

Full Changelog: https://github.com/apache/rocketmq/compare/rocketmq-all-5.2.0...rocketmq-all-5.3.0