pulsar

pulsar copied to clipboard

[improve][pip] PIP-377: Automatic retry for failed acknowledgements

2

### Motivation In the pip-377.md file ### Modifications In the pip-377.md file ### Documentation - [x] `doc` - [ ] `doc-required` - [ ] `doc-not-needed` - [ ] `doc-complete`

lhotari

[fix][broker] Fix various error-prone detected errors mainly in logging and String.format parameters

1

### Motivation error-prone detected some logging and String.format parameter errors in pulsar-broker module. ### Modifications - fix the issues ### Documentation - [ ] `doc` - [ ] `doc-required` -...

lhotari

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [x] I understand that [unsupported versions](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes....

lhotari

[improve][broker] Use atomic counter for ongoing transaction count

1

### Motivation Currently, `txnMetaMap.size()` is used to determine if a new transaction can be added and for metrics reporting. However, `txnMetaMap` is a `ConcurrentSkipListMap`, and calling `size()` is an O(n)...

3pacccccc

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [x] I understand that [unsupported versions](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes....

sandeep-mst

[fix][broker] Avoid split non-existent bundle

2

### Motivation ``` 2025-10-29T12:55:33,009+0000 [pulsar-modular-load-manager-37-1] INFO org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl - Successfully split namespace bundle cc/billing/0x80000000_0xc0000000 2025-10-29T12:55:33,009+0000 [pulsar-ordered-OrderedExecutor-0-0] INFO org.apache.pulsar.broker.namespace.OwnedBundle - Disabling ownership: xx/billing/0x80000000_0x93c58e36 2025-10-29T12:55:33,009+0000 [pulsar-ordered-OrderedExecutor-0-0] INFO org.eclipse.jetty.server.RequestLog - 10.247.8.118 - - [29/Oct/2025:12:55:32...

coderzc

[fix][broker]Fix incorrect backlog if use multiple acknowledge types on the same subscription

2

### Motivation **Background** By default, the backlog of a subscription is got by `{num of entries published} - {num of entries acknowleged}` - `num of entries published`: `ManagedLedger.entriesAddedCounter` - `num...

poorbarcode

[fix][admin] Refactor bookie affinity group sync operations to async in rest api

1

### Motivation It is not recommended to use sync operations in NIO threads, which would block other operations and degrade the overall performance of the system. ### Modifications Refactor bookie...

oneby-wang

### Motivation When a client sends an individual acknowledgment for a message that does not exist in the pending acknowledgment list (e.g., due to deletion or expiration), the method `getAckOwnerConsumerAndBatchSize`...

3pacccccc

[Bug] Auto topic delete of partitioned topics has a MetadataCacheImpl race condition

19

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [x] I understand that [unsupported versions](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes....

darinspivey