pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
### Motivation Trim BucketDelayedDeliveryTracker buckets if the topic ledgers trimmed. ### Modifications ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick...
### Motivation https://github.com/apache/pulsar/pull/6404 is to fix duplicated messages after broker restart(Especially for delayed messages). However, since we introduced https://github.com/apache/pulsar/pull/19035, it has to some extent solved this problem, but this logic...
### Motivation In some cases cursor position info can be too large to serialize as a single entry, e.g. in case of too many deleted ranges. Also the serialization can...
### Motivation For BucketDelayedDeliveryTracker, we store the Bucket metadata(position) in Cursor#properties, and remove the property *before* delete `ImmutableBucket`. There is a corner case that it could remove Cursor#properties succeed but...
### 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....
Fixes https://github.com/apache/pulsar/issues/22129 ### Motivation Pulsar uses binary search to find the message by timestamp, it will reduce the number of iterations to find the message, and make it more efficient...
### 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....
# Motivation Add comment for org.apache.pulsar.client.admin.Topics class. # Modifications Add comment for "applied" parameter in org.apache.pulsar.client.admin.Topics#getReplicationClusters and org.apache.pulsar.client.admin.Topics#getReplicationClustersAsync. # Documentation - [ ] `doc` - [ ] `doc-required` - [...
PIP: #21114 ### Motivation Consumer supports specifying consumption isolation level #21114 ### Modifications Add a configuration 'SubscriptionIsolationLevel' in consumer builder: ``` PulsarClient client = PulsarClient.builder().serviceUrl("pulsar://localhost:6650").build(); Consumer consumer = client.newConsumer(Schema.STRING) .topic("persistent://my-tenant/my-namespace/my-topic")...
PIP: 345 ### Motivation ### Modifications ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of the following options)* This...