pulsar

pulsar copied to clipboard

[improve][broker] optimize the problem of subscription snapshot cache not hitting

11

### Motivation - When message acknowledgment confirmation is slower than message consumption rate, subscription cursor synchronization fails to complete. This occurs because: 1. Current Behavior - With large receiver queues...

liudezhi2098

[Bug] Synchronization using geo's namespace-level replicas Message lost

5

### 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....

HGHNice

[Bug] unacked message count is zero when using exclusive subscription.

3

### Search before asking - [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 don't get bug fixes....

nodece

[improve][broker] Support consumer side delayed messages

1

Fixes #xyz Main Issue: #xyz PIP: #xyz ### Motivation When consumers encounter transient failures while processing messages, a common requirement is to retry processing after a certain delay. Before this...

Denovo1998

[Enhancement] Support getting message index in `ManagedLedger` interface

1

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation 1. [PIP-415](https://github.com/apache/pulsar/pull/24220) supports getting a message ID by index. This capability relies on...

liangyepianzhou

[Enhancement] Make cursor caching eligibility logic reactive since reads don't get cached until checkCursorsToCacheEntries has been called

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Currently broker cache doesn't cache entries until `checkCursorsToCacheEntries` has been called. It get...

lhotari

Flaky-test: ExtensibleLoadManagerImplTest.testLoadBalancerServiceUnitTableViewSyncer

1

### Search before reporting - [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/15293178018/job/43016333195?pr=24354#step:9:2457 ### Exception stacktrace ```text Error: Tests run: 99, Failures: 1, Errors:...

lhotari

[refactor][ml] Replace cache eviction algorithm with centralized removal queue and job

1

## Motivation This PR fixes fundamental inefficiencies and correctness issues in the current Pulsar **broker entry cache** eviction algorithm. The current implementation has flawed size-based eviction that doesn't remove the...

lhotari

[Bug] Retry topic without topic ({subscription_name}-RETRY) is getting created [broker >=3.0.6, and clients’ version is <3.0.6], related to PIP-344 compatibility

1

### 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....

sagar-upswing

[Bug] Compaction of __change_events topic is blocking forceful namespace/topic deletion

4

### Search before asking - [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 don't get bug fixes....

pdolif