pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
This is a followup to #17284. cc @DaveDuggins @Anonymitaet @momo-jun @urfreespace ### Documentation - [ ] `doc-required` (Your PR needs to update docs and you will update later) - [...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Currently in the Kafka Source we are not copyng the headers but only...
### Motivation Using this command `find . ! -name '*Test*' -name "*.java" -exec grep -H "@Test" {} \;` I found out that some tests are not running in the CI...
Fixes # Master Issue: # ### Motivation https://github.com/apache/pulsar/blob/master/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java#L190 ``` @Override public CompletableFuture readNextAsync() { CompletableFuture receiveFuture = consumer.receiveAsync(); receiveFuture.whenComplete((msg, t) -> { if (msg != null) { consumer.acknowledgeCumulativeAsync(msg).exceptionally(ex -> {...
### Motivation While working on https://github.com/apache/pulsar/pull/17752, I noticed our build time was incorrect. It was set to `2020-01-22T09:10:15-0600`. This timestamp was inherited from the org.apache:apache:23 dependency, as you can see...
### Motivation Cleanup unused sync method in NamespacesBase ### Modifications Removing `validatePolicies` and `internalSetTopicDispatchRate` ### Verifying this change - [ ] Make sure that the change passes the CI checks....
See CVE-2022-38752. ### Documentation - [ ] `doc-required` (Your PR needs to update docs and you will update later) - [x] `doc-not-needed` (Please explain why) - [ ] `doc` (Your...
### Motivation Current pulsar only support to set `autoSubscriptionCreation` on broker and namespace level, but we can further set this policy on the topic level. ### Modifications - Add admin...
### 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? When I go through the document...
### Motivation The TransactionImpl stores a lot of future. This uses a lot of memory, and can be optimized to two futures. ### Modification Optimize the future list to single...
