Apache RocketMQ Files

This release contains some important bug fix and improvement since version 5.3.0

What's Changed

• [ISSUE [#8375]] Add more test coverage for MqClientAdminImpl by @yx9o in https://github.com/apache/rocketmq/pull/8376
• [ISSUE [#8365]] Add remoting client non-oneway updateConsumerOffset function by @qianye1001 in https://github.com/apache/rocketmq/pull/8368
• [ISSUE [#8384]] Add more test coverage for ClientConfig by @yx9o in https://github.com/apache/rocketmq/pull/8385
• [ISSUE [#8350]] Fix properties store error: crc32ReservedLength make undefine mem… by @DongyuanPan in https://github.com/apache/rocketmq/pull/8351
• [ISSUE [#8365]] Add remoting client non-oneway updateConsumerOffset function by @qianye1001 in https://github.com/apache/rocketmq/pull/8391
• [ISSUE [#8372]] Add more test coverage for AdminBrokerProcessor by @TanXiang7o in https://github.com/apache/rocketmq/pull/8373
• [ISSUE [#8396]] Fix typo in TraceConstants by @yx9o in https://github.com/apache/rocketmq/pull/8398
• [ISSUE [#8392]] Add tests for QueryMessageProcessor by @TanXiang7o in https://github.com/apache/rocketmq/pull/8393
• [ISSUE [#8366]] Eliminate deadlocks during the client shutdown process. by @YanYunyang in https://github.com/apache/rocketmq/pull/8367
• [ISSUE [#8400]] Add tests for ConsumerManageProcessor by @TanXiang7o in https://github.com/apache/rocketmq/pull/8401
• [ISSUE [#8345]] Add some tests for nameserver by @TanXiang7o in https://github.com/apache/rocketmq/pull/8349
• [ISSUE [#8411]] Add more test coverage for DefaultMQPushConsumerImpl by @yx9o in https://github.com/apache/rocketmq/pull/8412
• [ISSUE [#8413]] Add some test cases for commom module by @yueranniu in https://github.com/apache/rocketmq/pull/8414
• [ISSUE [#8405]] Add the ability to write ConsumeQueue using fileChannel to prevent JVM crashes in some situations by @RongtongJin in https://github.com/apache/rocketmq/pull/8403
• [ISSUE [#8402]] Fix init retry topic offset incorrect when EscapeBridge enabled by @imzs in https://github.com/apache/rocketmq/pull/8404
• [ISSUE [#8421]] Add more test coverage for SlaveSynchronize by @TanXiang7o in https://github.com/apache/rocketmq/pull/8422
• [ISSUE [#8417]] Add some test cases for org.apache.rocketmq.common.AclConfig by @TeFuirnever in https://github.com/apache/rocketmq/pull/8418
• [ISSUE [#8409]] Fix tiered storage roll file logic if committing the last part of a file failed by @bxfjb in https://github.com/apache/rocketmq/pull/8410
• [ISSUE [#8437]] Add more test coverage for ClientRemotingProcessor by @yx9o in https://github.com/apache/rocketmq/pull/8433
• [ISSUE [#8438]] Fix broker return two messages when query message and index service bug by @lizhimins in https://github.com/apache/rocketmq/pull/8439
• [ISSUE [#8434]] Add test cases for org.apache.rocketmq.common.action by @TeFuirnever in https://github.com/apache/rocketmq/pull/8435
• [ISSUE [#8446]] Add more test coverage for MQClientInstance by @yx9o in https://github.com/apache/rocketmq/pull/8447
• [ISSUE [#8458]] Add more test coverage for ProcessQueue by @yx9o in https://github.com/apache/rocketmq/pull/8459
• [ISSUE [#8454]] Active brokers number should be initailized to 1 in broker heartbeat manager. by @ShannonDing in https://github.com/apache/rocketmq/pull/8453
• [ISSUE [#8448]] Commitlog class annotation optimize by @Qoozm in https://github.com/apache/rocketmq/pull/8452
• [ISSUE [#8429]] Fix trace message loss when traffic is heavy by @LetLetMe in https://github.com/apache/rocketmq/pull/8430
• [ISSUE [#8261]] Avoid unnecessary waiting when a response is successfully returned by @3424672656 in https://github.com/apache/rocketmq/pull/8272
• [ISSUE [#8332]] Fix ack msg which has reached maxReconsumeTimes by @cserwen in https://github.com/apache/rocketmq/pull/8333
• [ISSUE [#7731]] Fix runBroker.cmd cannot start on Windows (#7731) by @hackjus in https://github.com/apache/rocketmq/pull/8338
• [ISSUE [#8465]] Add more test coverage for ConsumeMessagePopConcurrentlyService by @yx9o in https://github.com/apache/rocketmq/pull/8466
• [ISSUE [#8432]] Make autoDeleteUnusedStats default to true by @RongtongJin in https://github.com/apache/rocketmq/pull/8431
• [ISSUE [#8463]] Some statistical items should also be deleted to prevent memory leakage when a topic or group is deleted by @RongtongJin in https://github.com/apache/rocketmq/pull/8464
• [ISSUE [#8472]] Fix pop message delay due to not notify message arriving after suspend by @lizhimins in https://github.com/apache/rocketmq/pull/8473
• only initialize all the variables once to speed up test ConsumeMessageConcurrentlyServiceTest by @TestBoost in https://github.com/apache/rocketmq/pull/8436
• [ISSUE [#8460]] Improve the pop revive process when reading biz messages from a remote broker by @imzs in https://github.com/apache/rocketmq/pull/8475
• [ISSUE [#8476]] Add test cases for org.apache.rocketmq.common.attribute by @TeFuirnever in https://github.com/apache/rocketmq/pull/8477
• [ISSUE [#8490]] Fix getMaxReconsumeTimes calculation error in concurrent consumption mode by @yx9o in https://github.com/apache/rocketmq/pull/8491
• [ISSUE [#8495]] Add more test coverage for PeekMessageProcessor by @TanXiang7o in https://github.com/apache/rocketmq/pull/8498
• [ISSUE [#8481]] Improve delete and rolling strategy for tiered storage modules by @lizhimins in https://github.com/apache/rocketmq/pull/8493
• [ISSUE [#8486]] Add more test coverage for BrokerMetricsManager by @ziiyee in https://github.com/apache/rocketmq/pull/8487
• [ISSUE [#8500]] Add more test coverage for RocksDBLmqConsumerOffsetManager by @StudentGu in https://github.com/apache/rocketmq/pull/8502
• [ISSUE [#8496]] Add more test coverage for ConsumeMessagePopOrderlyService by @yx9o in https://github.com/apache/rocketmq/pull/8497
• [ISSUE [#8503]] Add test cases for org.apache.rocketmq.common.chain/coldstr/compression/consumer by @TeFuirnever in https://github.com/apache/rocketmq/pull/8504
• [ISSUE [#8514]] Fix bazel-compile (ubuntu-latest) ci run failure by @yx9o in https://github.com/apache/rocketmq/pull/8515
• [ISSUE [#8510]] Fix CI Failure in Test E2E Golang Job of PUSH-CI and PR-E2E-TEST by @chi3316 in https://github.com/apache/rocketmq/pull/8520
• [ISSUE [#8499]] Modify batch send delay time to 3000ms in unit test. by @ShannonDing in https://github.com/apache/rocketmq/pull/8522
• [ISSUE [#8517]] Fix client send UNREGISTER_CLIENT request twice may cause proxy NPE by @qianye1001 in https://github.com/apache/rocketmq/pull/8528
• [ISSUE [#8517]] Add more test coverage for PullAPIWrapper by @yx9o in https://github.com/apache/rocketmq/pull/8518
• [ISSUE [#8460]] Improve the pop revive process when reading biz messages from a remote broker - part2 by @imzs in https://github.com/apache/rocketmq/pull/8494
• [ISSUE [#8532]] Fix flush metadata when commit file because of full file by @bxfjb in https://github.com/apache/rocketmq/pull/8533
• [ISSUE [#8531]] Update jaeger-thrift, exclude unnecessary tomcat-embed-core by @leizhiyuan in https://github.com/apache/rocketmq/pull/8536
• [ISSUE [#8289]] Fixed network bugs and merged networkutil code by @zekai-li in https://github.com/apache/rocketmq/pull/8290
• [ISSUE [#8519]] Add test case for rocketmq acl module. by @HardX8 in https://github.com/apache/rocketmq/pull/8508
• [ISSUE [#8517]] Add more test coverage for PullMessageService by @yx9o in https://github.com/apache/rocketmq/pull/8542
• [ISSUE [#8544]] Add a retry mechanism to the unit test pipeline by @chi3316 in https://github.com/apache/rocketmq/pull/8545
• [ISSUE [#8547]] Add more ControllableOffset by @syhleo in https://github.com/apache/rocketmq/pull/8548
• [ISSUE [#8551]] Add more test coverage for AuthMigrator by @yx9o in https://github.com/apache/rocketmq/pull/8552
• [ISSUE [#8534]] Supports timer message queries by @leizhiyuan in https://github.com/apache/rocketmq/pull/8535
• [ISSUE [#8565]] Set specific permissions to trigger the workflow retry mechanism by @chi3316 in https://github.com/apache/rocketmq/pull/8566
• [ISSUE [#8553]] Add UnitTest of OffsetSerialize by @syhleo in https://github.com/apache/rocketmq/pull/8554
• [ISSUE [#8562]] Add more test coverage for StatefulAuthorizationStrategy by @yx9o in https://github.com/apache/rocketmq/pull/8563
• [ISSUE [#8549]] Ipv6 enabled in broker, pickupStoreTimestamp size should be 20 by @leizhiyuan in https://github.com/apache/rocketmq/pull/8567
• [ISSUE [#8555]] Make ctx constructed in scheduleRenewTask by @qianye1001 in https://github.com/apache/rocketmq/pull/8556
• [ISSUE [#8058]] Support for upgrading metadata in json to rocksdb (#8045) by @LetLetMe in https://github.com/apache/rocketmq/pull/8571
• [ISSUE [#8573]] Correct mismatched comments by @yx9o in https://github.com/apache/rocketmq/pull/8574
• fix document typo in SlaveActingMasterMode.md by @maclong1989 in https://github.com/apache/rocketmq/pull/8575
• [ISSUE [#8544]] Restore retry mechanism in unit test pipeline by @chi3316 in https://github.com/apache/rocketmq/pull/8581
• [ISSUE [#8137]] Support pop consumption for light message queue by @HScarb in https://github.com/apache/rocketmq/pull/8138
• [ISSUE [#8576]] Support Creating or Updating Subscription Groups in Batch by @caigy in https://github.com/apache/rocketmq/pull/8577
• [ISSUE [#8586]] Add more test coverage for SelectMessageQueueByRandom by @yx9o in https://github.com/apache/rocketmq/pull/8587
• [ISSUE [#8592]] Not notify long polling request when pop orderly consume blocked by @lizhimins in https://github.com/apache/rocketmq/pull/8593
• [ISSUE [#8607]] Exclude loopback addresses when iterating over local network interfaces by @chi3316 in https://github.com/apache/rocketmq/pull/8608
• [ISSUE [#8601] ]When isPopShouldStop hit,unlock queueLockManager by @leizhiyuan in https://github.com/apache/rocketmq/pull/8602
• [ISSUE [#8591]] Preliminary support for key commands of LMQ by @RongtongJin in https://github.com/apache/rocketmq/pull/8590
• [ISSUE [#8483]] Optimize unnecessary broker reverse notification (notifyConsumerIdsChanged) in broadcast mode by @yx9o in https://github.com/apache/rocketmq/pull/8484
• [ISSUE [#8584]] Fix missing brokerName in sendMessageBack request by @yuz10 in https://github.com/apache/rocketmq/pull/8585
• [ISSUE [#8623]] Temporarily skip flaky unit tests on macOS by @chi3316 in https://github.com/apache/rocketmq/pull/8633
• [ISSUE [#8596]] Remove redundant mvn test and log check steps from CI workflow by @chi3316 in https://github.com/apache/rocketmq/pull/8637
• [ISSUE [#8609]] Add the BrokerConfig updateNameServerAddrPeriod by @qianye1001 in https://github.com/apache/rocketmq/pull/8626
• [ISSUE [#8643]] Add an integration testing pipeline to current CI workflow by @chi3316 in https://github.com/apache/rocketmq/pull/8644
• [ISSUE [#8599]] Fix send fail without retry when get GO_AWAY twice by @qianye1001 in https://github.com/apache/rocketmq/pull/8603
• [ISSUE [#8640]] Add more test coverage for Broker2Client by @yx9o in https://github.com/apache/rocketmq/pull/8641
• [ISSUE [#8649]] Fix Generate coverage report ci error by @yx9o in https://github.com/apache/rocketmq/pull/8650
• [ISSUE [#8647]] Fix the issue where lmq cannot update consumer offset by @RongtongJin in https://github.com/apache/rocketmq/pull/8648
• [ISSUE [#8657]] Make retry topic pop probability configurable by @GenerousMan in https://github.com/apache/rocketmq/pull/8658
• [ISSUE [#8668]] Improve CI pipeline reliability with better log viewing and test fixes by @chi3316 in https://github.com/apache/rocketmq/pull/8667
• [ISSUE [#8653]] Fix index service upload last file when broker shutdown and fetcher check in tiered storage by @lizhimins in https://github.com/apache/rocketmq/pull/8654
• [ISSUE [#8660]] Feat: should use read only getConsumeQueue instead of findConsumeQueue in read only func by @absolute8511 in https://github.com/apache/rocketmq/pull/8659
• [ISSUE [#8665]] Add more test coverage for RebalanceLockManager by @yx9o in https://github.com/apache/rocketmq/pull/8666
• [ISSUE [#8669]] Fix crc 32 overflow when lmq by @DongyuanPan in https://github.com/apache/rocketmq/pull/8670
• [ISSUE [#8259]] Fix parse ipv6 from address in haproxy by @yuz10 in https://github.com/apache/rocketmq/pull/8260
• [ISSUE [#8688]] Fix typo, release the write lock in forceUpload() by @imzs in https://github.com/apache/rocketmq/pull/8689
• [ISSUE [#8599]] Fix send fail with receiving GO_AWAY when rolling update proxy and add channel id in logs by @qianye1001 in https://github.com/apache/rocketmq/pull/8685
• [ISSUE [#8691]] Fix PR-CI errors by @yx9o in https://github.com/apache/rocketmq/pull/8692
• [ISSUE [#8695]] Fix DefaultLitePullConsumer PullThreadNums Parameter not effective. by @luozongle01 in https://github.com/apache/rocketmq/pull/8696
• [ISSUE [#8613]] Fix start failed when acl2.0 authentication enabled and authorization disabled by @kingkh1995 in https://github.com/apache/rocketmq/pull/8614
• [RIP-70-1] Optimize the back pressure mechanism of the client by @3424672656 in https://github.com/apache/rocketmq/pull/8661
• [ISSUE [#8693]] Fix checking MultiDispatchMessage when appending commitlog by @redlsz in https://github.com/apache/rocketmq/pull/8700
• [ISSUE [#8707]] Fix artifact download failure in CI after action upgrade by @chi3316 in https://github.com/apache/rocketmq/pull/8708
• [ISSUE [#8681]] Fix trace topic name by @yuz10 in https://github.com/apache/rocketmq/pull/8680
• [ISSUE [#8671]] Replace channel.attr() set() and get() with RemotingHelper by @qianye1001 in https://github.com/apache/rocketmq/pull/8710
• Fix typo in BaseConf by @Lovelcp in https://github.com/apache/rocketmq/pull/8679
• [ISSUE [#8705]] Make MQClientAPIFactory shutdown async by @qianye1001 in https://github.com/apache/rocketmq/pull/8706
• [ISSUE [#8718]] Fix flaky CreateAndUpdateTopicIT by @RongtongJin in https://github.com/apache/rocketmq/pull/8717
• [ISSUE [#8720]] Support disable netty server worker group by config by @lizhimins in https://github.com/apache/rocketmq/pull/8721
• [ISSUE [#8604]] Fix doc typo by @yx9o in https://github.com/apache/rocketmq/pull/8605
• [ISSUE [#8712]] Set namesrvAddrChoosed to null if choosed addr is not exist. by @qianye1001 in https://github.com/apache/rocketmq/pull/8713
• [ISSUE [#8589]] Support file format CQ and json format offset in-place upgrade to rocksdb management by @LetLetMe in https://github.com/apache/rocketmq/pull/8600
• [ISSUE [#8742]] Enhance unit test retry mechanism to trigger on PR submission by @chi3316 in https://github.com/apache/rocketmq/pull/8741
• [ISSUE [#8740]] Fix rocksDBConfigToJson command by @yuz10 in https://github.com/apache/rocketmq/pull/8738
• [ISSUE [#8747]] Fix PR E2E artifact download issue by @chi3316 in https://github.com/apache/rocketmq/pull/8748
• [ISSUE [#8698]] Remove batch write in kv cq store and update rocksdb cq check tool by @LetLetMe in https://github.com/apache/rocketmq/pull/8739

New Contributors

• @TanXiang7o made their first contribution in https://github.com/apache/rocketmq/pull/8373
• @YanYunyang made their first contribution in https://github.com/apache/rocketmq/pull/8367
• @yueranniu made their first contribution in https://github.com/apache/rocketmq/pull/8414
• @TeFuirnever made their first contribution in https://github.com/apache/rocketmq/pull/8418
• @Qoozm made their first contribution in https://github.com/apache/rocketmq/pull/8452
• @hackjus made their first contribution in https://github.com/apache/rocketmq/pull/8338
• @TestBoost made their first contribution in https://github.com/apache/rocketmq/pull/8436
• @ziiyee made their first contribution in https://github.com/apache/rocketmq/pull/8487
• @StudentGu made their first contribution in https://github.com/apache/rocketmq/pull/8502
• @chi3316 made their first contribution in https://github.com/apache/rocketmq/pull/8520
• @zekai-li made their first contribution in https://github.com/apache/rocketmq/pull/8290
• @HardX8 made their first contribution in https://github.com/apache/rocketmq/pull/8508
• @syhleo made their first contribution in https://github.com/apache/rocketmq/pull/8548
• @luozongle01 made their first contribution in https://github.com/apache/rocketmq/pull/8696
• @Lovelcp made their first contribution in https://github.com/apache/rocketmq/pull/8679

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