pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
Fixes https://github.com/apache/pulsar/issues/14875 ### Motivation The client connections can be closed when doing handshake, add `ConnectionFailedException` to make this kind of exception more clear. ### Modifications ### Verifying this change...
**Is your enhancement request related to a problem? Please describe.** Since Pulsar 2.9.X, the pulsar system is able to produce message directly to the broker from the REST client. It...
### Motivation PIP-359 Implementation PR：https://github.com/apache/pulsar/pull/22861 ### Modifications ### Verifying this change - [x] Make sure that the change passes the CI checks. *(Please pick either of the following options)* This...
### Motivation Using package API to upload a large package may cause broker OOM. Because in the current implementation, will copy all data to the heap. https://github.com/apache/pulsar/blob/2c6fcc7eb8343583ffb48dec937334a5f05afbae/pulsar-package-management/bookkeeper-storage/src/main/java/org/apache/pulsar/packages/management/storage/bookkeeper/DLOutputStream.java#L60-L65 ### Modifications Each...
(cherry-picked from commit https://github.com/apache/pulsar/commit/36bae695fb07f3ee790bee603149c4c2712187e0) ### Motivation Cherry-picked from #22378 ### Modifications ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either...
[PIP-264](https://github.com/apache/pulsar/blob/master/pip/pip-264.md) ### Motivation Adds Managed Ledger metrics, as currently described [here](https://pulsar.apache.org/docs/next/reference-metrics/#managedledger-metrics), to the OpenTelemetry pipeline. ### Modifications - Adds the metrics described in https://github.com/apache/pulsar-site/pull/930 to the collector runs. ### Verifying...
### Motivation catch issues like https://github.com/apache/pulsar/issues/22051 ### Modifications Added a test for upgrade/downgrade ### Verifying this change - [ ] Make sure that the change passes the CI checks. This...
[fix][client] Fix pattern consumer create crash if a part of partitions of a topic have been deleted
### Motivation #### Background **1.Regarding the API getting topics by regexp pattern, there are two implementations:*** - `List HttpLookupService.getPartitionedTopicMetadata(...)` - `CommandGetTopicsOfNamespace BinaryProtoLookupService.getPartitionedTopicMetadata(...)` Pulsar transferred both response types `List` and `CommandGetTopicsOfNamespace`...
### Motivation Implementation PR for PIP: https://github.com/apache/pulsar/pull/22946. ### Modifications - Introduce new algo: AvgShedder. - provide a way to bind shedding strategy and placement strategy. ### Verifying this change -...
### 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....
