pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
### Motivation C++ client Support KeyValue Schema. For key and value schema, just only support `AVRO` and `JSON` type(consistent with java client). ### Modifications - A new constructor is added...
### Motivation https://github.com/apache/pulsar/issues/17140 ### Modifications - Consumer support batch receives messages. - Abstract common implementation to `ConsumerImplBase`. - `acknowledge(Messages messages)` is not supported for the time being, and it needs...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation I try to build cpp client with `static` flag, and it seems that...
### Motivation In the actual production environment, users may only use one default namespace (public/default). The number of bundles in this namespace is a default value of 16. 1. if...
### Motivation If `label_cluster` specified `cluster_123`, the expected metrics text is: ``` metrics_xxx_total{cluster="cluster_123"} 1.0 ``` but the exactly metrics text is : ``` metrics_xxx_totalcluster="cluster_123"} 1.0 ``` High light: lost a...
### Motivation The existing ThresholdShedder has the following problems, for example: There are 11 Brokers, of which 10 are loaded at 80% and 1 is loaded at 0%. The average...
### Motivation Currently, Pulsar Prometheus metric framework can generate new metrics from `PrometheusRawMetricsProvider`, and the current PrometheusMetricsProvider implementation doesn't support this interface, which leads to new created PrometheusMetricProvider instance can...
Fixes #17747 ### Motivation `PerformanceConsumer` command line tool does not use its `-m` flag thus misleading its users. ### Modifications Check the total number of messages received against `numMessages` if...
### Motivation Skip numOfEntriesToRead entries instead of skipping a ledger. When isAutoSkipNonRecoverableData=true, if a NonRecoverableLedgerException exception occurs when reading data, readPosition will automatically adjust to the next ledger to continue...
### Motivation Currently owasp ci check fails on branch-2.10. See https://github.com/Jason918/pulsar/actions/runs/3088190603/jobs/4994380011#step:8:53 ``` Error: Failed to execute goal org.owasp:dependency-check-maven:7.1.0:aggregate (default) on project distribution: Error: Error: One or more dependencies were identified...
