pulsar

pulsar copied to clipboard

[New Website] Set up Matomo (an alternative to Google Analytics)

3

Comments from @dave2wave: Google Analytics are no longer allowed on ASF websites due to privacy concerns. See https://privacy.apache.org/policies/website-policy.html This is a new policy. The privacy committee has setup an alternative...

Anonymitaet

[Bug] How to solve or optimize this problem [Client memory buffer is full]

7

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 2.10.1 master ### Minimal reproduce step When we call the client for a...

rogueVpedro

Tracking issue for slow tests

3

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation This issue tracks efforts to optimize slow testing(which took more than 5 minutes),...

poorbarcode

PIP-220: TransferShedder

2

### Motivation 1. As PIP-192 enables the `bundle transfer protocol`, we could implement a new shedding strategy to specify a new owner broker. 2. Improve the edge cases in the...

heesung-sohn

[fix][broker]fix Repeated messages of shared dispatcher

1

Fixes #16795 ### Motivation In `Shard` mode: 1. When redelivering some message, will trigger the next read. 1. When closing the lastest consumer or adding the first consumer, will trigger...

poorbarcode

Fixes #18232 ### Motivation https://github.com/poorbarcode/pulsar/actions/runs/3267034877/jobs/5371836130 https://github.com/apache/pulsar/actions/runs/3242148385/jobs/5326408439 The original implementation determines whether to wait for the creation of `__chang_event` based on whether a broker has taken ownership of the bundle or...

poorbarcode

### Motivation Pulsar doesn't have [offload](https://pulsar.apache.org/docs/tiered-storage-overview) throttling for now. With offload, pulsar could move backlog data from bookkeeper to some other long term storage which is cheaper(AWS S3, Aliyun OSS,...

tjiuming

[fix][broker]Fix using schema to create consumer fails after using AUTO_CONSUME consumer to subscribe topic

13

Fixes #17354 ### Motivation *Fixed the failure to use schema to create consumer after using AUTO-CONSUME consumer to subscribe an empty topic, and Broker returned the error message as `IncompatibleSchemaException("Topic...

Denovo1998

PIP-218: Consumer batchReceive() single partition every receive

2

### Motivation Currently, client API does not use `acknowledgeCumulative` simple and easy to understand. If the user uses the receive() interface to consume multi-partition topic, there are two ways to...

congbobo184

[improve][client] Throw more meaningful derived exception instead of PulsarClientException

18

### Motivation Currently we are abuse `PulsarClientException`, I think we could use a more meaningful derived exception instead. For example, call `acknowledge` on an already closed consumer throws PulsarClientException with...

Shawyeok