pulsar
pulsar copied to clipboard
Apache Pulsar - distributed pub-sub messaging system
### Motivation 1. When we delete a namespace by force if the __transaction_buffer_snapshot and __change_events be deleted first, and then the deleting of the normal topic will be failed at...
### Motivation The [Kubernetes (Helm)](https://pulsar.apache.org/docs/helm-overview) chapter mainly talks about the deployment. There are many unnecessary Xrefs, for example, the [deployment](https://pulsar.apache.org/docs/next/deploy-kubernetes) topic only provides an Xref to the installation topic, and...
Fixes #18292 ### Motivation fix creating lots of ledgers for the same schema ### Modifications when putting schema to zk failed, do not retry directly, but read the latest persistent...
### Motivation There are duplicate codes in `org.apache.pulsar.client.impl.ConsumerBuilderImpl#topic` and `org.apache.pulsar.client.impl.ConsumerBuilderImpl#topics`, `org.apache.pulsar.client.impl.ConsumerBuilderImpl#topicsPattern(java.util.regex.Pattern)` and `org.apache.pulsar.client.impl.ConsumerBuilderImpl#topicsPattern(java.lang.String)`. ### Modifications Merge the duplicate codes in `org.apache.pulsar.client.impl.ConsumerBuilderImpl#topic` and `org.apache.pulsar.client.impl.ConsumerBuilderImpl#topics`, `org.apache.pulsar.client.impl.ConsumerBuilderImpl#topicsPattern(java.util.regex.Pattern)` and `org.apache.pulsar.client.impl.ConsumerBuilderImpl#topicsPattern(java.lang.String)`. ### Verifying this change...
### Motivation `org.apache.pulsar.broker.admin.impl.PersistentTopicsBase#internalCreateMissedPartitions` lacks the logic to create subscriptions. ### Modifications - add `org.apache.pulsar.broker.admin.impl.PersistentTopicsBase#createMissedSubscriptionsAsync` - add the logic for creating missed subscriptions for `org.apache.pulsar.broker.admin.impl.PersistentTopicsBase#internalCreateMissedPartitions` ### Verifying this change - [x]...
### Motivation Broker uses the `Trimledgers` thread to clean up outdated ledgers. During cleaning, each Broker traverses the topic metadata in memory to find the ledger that reach the retention...
### Motivation remove legacy code ### Modifications remove legacy code ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of...
### What issue do you find in Pulsar docs? New 2.10.0 pulsar now supported ETCD as metadata store and we would like to migrate current zookeeper to etcd. Is it...
Master Issue: https://github.com/apache/pulsar/issues/18099 ### Motivation This PR supports `TopicCompactionStrategy` in `StrategicTwoPhaseCompactor` and `TableView` for the internal system topics, as proposed in PIP-215. This PR does not expose StrategicTwoPhaseCompactor for customer...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### What issue do you find in Pulsar docs? If you check https://pulsar.apache.org/api/cpp/ There's no...