pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
Master Issue: #15370 ### Motivation see #15370 ### Modifications I will complete proposal #15370 with these pull requests( *current pull request is a part of step 7-1* ): 1. Write...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Ubuntu 20.04 Pulsar 2.7.0 Cluster setup 5 zookeeper 5 bookkeeper 5 broker -...
**Is your enhancement request related to a problem? Please describe.** Pulsar doesn't take advantage of Bookkeeper's client-side and server-side backpressure features. https://github.com/apache/bookkeeper/issues/1086 and https://github.com/apache/bookkeeper/issues/1409 are the original Bookkeeper issues about...
Signed-off-by: Zixuan Liu ### Motivation Miss close the function worker when the PulsarService close method is called, which introduces an [issue](https://github.com/apache/pulsar/issues/16538) in the test if we don't close the function...
Fixes #8407 Fixes #13865 ### Motivation Current broker prometheus metrics are not grouped by metric type which causes issues in systems that read these metrics (e.g. DataDog). Prometheus docs states...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation In [PIP-121](https://github.com/apache/pulsar/issues/13315)，we support cluster level controlled cluster failover on client side。But I have...
Master Issue: #12271 #16991 ### Motivation Apply Maven Modernizer plugin to enforce we move away from legacy APIs. ### Modifications Add Maven Modernizer plugin in pulsar-broker module and fix violation....
issue: reproduce: 1. redeliver one consumer received message of a batch message, will remove this message from this consumer pending acks 2. if this message is removed and doesn't redeliver...
### Motivation the prompt message is wrong. ### Modifications change the prompted message.
issue: reduce the consumer `unackedCount` use incorrect consumer. reproduce step ``` for (int i = 0; i < 5; i++) { producer.newMessage().value(("Hello Pulsar - " + i).getBytes()).sendAsync(); } // consume-1...