pulsar

pulsar copied to clipboard

[Bug] Thread safety issues with topic policy mutations

6

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Since 2.11 ### Minimal reproduce step Topic policies are stored in system topics...

lhotari

[pip][design] PIP-269. Add an epoch of cursor to discard outdated reading

10

### Motivation & Modifications Start a PIP: Add an epoch of cursor to discard outdated reading ### Documentation - [ ] `doc` - [x] `doc-required` - [ ] `doc-not-needed` -...

poorbarcode

[Bug] pulsar-proxy Liveness probe failed: HTTP probe failed with statuscode: 401

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version kubernetes：1.28.4 pulsar-helm-chart：3.2.0 apachepulsar/pulsar-all：3.1.2 ### Minimal reproduce step 1. `helm install pulsar --values charts/pulsar/values.yaml...

Awsmsniper

Flaky-test: SimpleProducerConsumerTest.testMultiTopicsConsumerImplPauseForManualSubscription

2

### 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/5140514539/jobs/9252318146?pr=20267#step:10:1498 ### Exception stacktrace ``` Error: Tests run: 281, Failures: 2, Errors:...

michaeljmarshall

[Enhancement] Improve Pulsar Broker memory usage metrics which are also used in the Pulsar Load Manager

4

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Currently Pulsar uses heap usage as one of the resource metrics for the...

lhotari

[fix][broker] Fix recentlyJoinedConsumers to address the out-of-order issue

6

### Motivation The Key_Shared subscription type has the following issues. 1. Key_Shared subscription has out-of-order cases because of the race condition of [the recently joined consumers feature](https://github.com/apache/pulsar/blob/35e9897742b7db4bd29349940075a819b2ad6999/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java#L400-L408). Consider the following...

equanz

[Bug] After upgrading to 3.0, some metrics were lost in bk.

3

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 3.0.2 ### Minimal reproduce step   Details: - bookkeeper_server_ADD_ENTRY_REQUEST - bookkeeper_server_ADD_ENTRY_BLOCKED -...

crossoverJie

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version master ### Minimal reproduce step The last message id from binary protocal is...

thetumbled

[Bug] Msg backlog & unack msg remains when using acknowledgeAsync

12

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 3.0.0 ### Minimal reproduce step 1. Publish 600k messages 2. Start 2 consumers...

pqab

[improve] [broker] Handle ReplicatedSubscriptionsSnapshots when it arrives to fix issues in replicating subscription state to remote clusters

9

Fixes #10054 ### Motivation There's a long-standing issue #10054 where replicated subscriptions were not working correctly across clusters. The test case `testReplicatedSubscriptionAcrossTwoRegions` demonstrate the issue: https://github.com/apache/pulsar/blob/a1a2b363cfaa1bbc38933a742484a70a0a56e761/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatedSubscriptionTest.java#L107-L116 the test has been...

lhotari