pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
**Describe the bug** When there has a bookie is slowly to respond the add entry request, and the AQ is smaller than WQ, broker will OOM. **To Reproduce** 1. Change...
when use key store tls connect broker,while ip change to 127.0.0.1? [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xdded1946, L:/10.25.xxx.xx:58107 - R:/7.xx.xx.xx:21852]] Connected to server [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer...
### What issue do you find in Pulsar docs? The property "pulsar.allocator.leak_detection" has wrong description: "Service URL provider for Pulsar service" ### What is your suggestion? n/a ### Do you...
### Documentation Check the box below or label this PR directly. Need to update docs? - [ ] `doc-required` (Your PR needs to update docs and you will update later)...
In this comment https://github.com/apache/pulsar/pull/16884#issuecomment-1201512995 I wrote: > I don't like powermock as it lacks maintenance. It seems all usage of powermock is `Whitebox`. We can get rid of it with...
### Motivation Cherry pick the #16526 and #16935. ### Documentation Check the box below or label this PR directly. Need to update docs? - [ ] `doc-required` (Your PR needs...
BookKeeperPackagesStorageTest.setUp is flaky. It fails sporadically. [example failure](https://github.com/apache/pulsar/runs/6586743061?check_suite_focus=true#step:10:16369) ``` Error: Tests run: 11, Failures: 1, Errors: 0, Skipped: 3, Time elapsed: 87.06 s
``` Error: Tests run: 4, Failures: 1, Errors: 0, Skipped: 3, Time elapsed: 78.765 s
``` Error: Tests run: 14, Failures: 6, Errors: 0, Skipped: 7, Time elapsed: 21.986 s
[feature][broker] Support cgroup v2 by using `jdk.internal.platform.Metrics` in Pulsar Loadbalancer
Master Issue: #16601 ### Motivation The Pulsar load balancer detects CPU limits using cgroup v1 API, and the `jdk.internal.platform.Metrics` already support cgroup (V1, v2) so we should use `jdk.internal.platform.Metrics` to...
