lifepuzzlefun

[ISSUE #3229] check running status when schedule new DeliveryMessageTimerTask.

4

when ScheduleMessageService stoped. the timer canceled. and new schedule task will cause exception. then show "ScheduleMessageService, messageTimeup execute error, drop it. msgExt" in log.

Security Advisories from deps.dev

4

see https://deps.dev/go/github.com%2Fapache%2Frocketmq-client-go%2Fv2

see https://github.com/apache/rocketmq-client-cpp/blob/6523dcc3b309a1065375e40657f68f66bfeca38d/src/consumer/SubscriptionData.cpp#L107-L113 the serialize string in rockemq broker is long. i think this should keep the same as broker implementation

[MINOR] Code refactor Bookie env check during start.

6

[MINOR] code refactor Bookie env check during start. move bookie environment check logic code to `BookieEnvirnmentChecker` this may makes code much clearer. no logic change or method delete.

[cleanup][txn] Avoid unnessary method call if txn disabled.

3

Fixes #18324 ### Motivation avoid unnecessary method call if txn disabled. ### Modifications 1. remove `isTxnEnabled` parameter in `TransactionBuffer.checkIfTransactionBufferRecoverCompletely`. 2. check isTxnEnabled before call txn related code in common code...

[improve][broker] Code simplify in `AbstractBaseDispatcher` in filterEntriesForConsumer loop

1

Fixes #18328 ### Modifications 1. batch `subscription.acknowledgeMesage` in filterEntriesForConsumer loop 2. remove unnecessary Optional package parameter for `filterEntriesForConsumer` metadataArray 3. avoid call O(consumer) times of `topic.getMigratedClusterUrl` in `checkAndApplyReachedEndOfTopicOrTopicMigration` ### Verifying...

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation 1. batch `subscription.acknowledgeMesage` in filterEntriesForConsumer loop 2. remove unnecessary Optional package parameter for...

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Avoid unnessary method call if txn disabled. ### Solution check before method called...

Flaky-test: ExtensibleLoadManagerImplTest.initializeState

16

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/actions/runs/4755217144/jobs/8449646027 ### Exception stacktrace don't know how to find stacktrace. ### Are...