pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
[example failure](https://github.com/apache/pulsar/runs/7710408158?check_suite_focus=true#step:10:1407) ``` Error: Tests run: 10, Failures: 3, Errors: 0, Skipped: 7, Time elapsed: 129.61 s
### Motivation remove unused code ### Documentation Check the box below or label this PR directly. Need to update docs? - [ ] `doc-required` (Your PR needs to update docs...
### Motivation PR #16968 made changes to the logic how sendInProgress field is set in `PersistentDispatcherMultipleConsumers` class and a decision was made [in a post-merge review](https://github.com/apache/pulsar/pull/16968#discussion_r940533777) to revert the changes....
### Motivation Incorrectly scaled resource load usage(cpu, memory, network usages bigger than 100%) can harm the load computation in the load balancer logics, as the load balancer computation expects all...
Fixes #17014 ### Motivation The root cause of #17014 is a race condition in the `batchMessageContainer` when discarding the messages and releasing the semaphore. We need to release semaphore first...
### Motivation When there are many partitioned topics under a namespace, deleting the namespace forcibly will fail, because many requests update ns policies simultaneously and cause the metadata store throws...
Fixes #16804 ### Motivation The property "pulsar.allocator.leak_detection" has wrong description: "Service URL provider for Pulsar service" in https://pulsar.apache.org/docs/client-libraries-java/#client-memory-allocator-configuration. In addition, this PR also remove 'Client memory allocator configuration' section from...
### Motivation There is only a simple word `Default message retention time/size` on `defaultRetentionTimeInMinutes=0` and `defaultRetentionSizeInMB=0` in broker.conf. I think it is not clear for users because `0` and `-1`...
# PIP-195: New bucket based delayed message tracker Discussion Mailing list thread: https://lists.apache.org/thread/1krdhrvs803kb6rqzdh17q0f199nroz4 Vote Mailing list thread: https://lists.apache.org/thread/51n8kp64d16vxwh9h6klvyh1zo0owf91 ## Motivation Scheduled and delayed message delivery is a widespread feature in...
### Motivation Although the configuration loadBalancerSheddingIntervalMinutes is marked as dynamic=true, it cannot be changed dynamically. When loadSheddingTask is initialized, the shed interval is fixed: https://github.com/apache/pulsar/blob/4d64e2e66689381ebbb94fbfc03eb4e1dfba0405/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java#L1051-L1053 https://github.com/apache/pulsar/blob/4d64e2e66689381ebbb94fbfc03eb4e1dfba0405/pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java#L2087-L2093 ### Documentation Check the...