pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
Fixes https://github.com/apache/pulsar/issues/16674 ### Motivation Add doc for https://github.com/apache/pulsar/pull/16675 ### Modifications *Describe the modifications you've done.* ### Verifying this change - [ ] Make sure that the change passes the CI...
Fixes #16761 ### Motivation When C++ client calls `ConsumerImpl::getLastMessageIdAsync`, if the connection is not established, the callback will complete with `ResultNotConnected`. ### Modifications * Wait until the connection is established...
**Describe the bug** The benchmark test is for the max throughput scenario with 1GB/s message writing and 1GB/s message reading. ``` Aug 08 17:44:23 ip-10-0-0-158.us-west-2.compute.internal pulsar[25809]: 2022-08-08T17:44:23,714+0000 [BookKeeperClientWorker-OrderedExecutor-20-0] ERROR org.apache.bookkeeper.client.MetadataUpdateLoop...
Fixes #16321
[example failure](https://github.com/apache/pulsar/runs/7710408370?check_suite_focus=true) ``` Error: Tests run: 64, Failures: 16, Errors: 0, Skipped: 48, Time elapsed: 604.061 s
Master issue: #12271 (2022-08-08 branch=master) I scan the broker, found **617** places to change. we need to split them into multiple PRs. ``` - src/main: 176 - src/test: 441 -...
### Motivation Compare the namespace offload policy, the topic offload policy command line update function use `int` and `long` type to accept param and miss some param check method, which...
### Motivation Steps to reproduce: 1. grant permission for role1 on topic "persistent://public/default/test" 2. revoke permission for role1 on topic "persistent://public/default/test" 3. zk remain empty record, as shown in the...
### Motivation Now, Use a lot of locks to ensure the atomicity of `state_` in the `ConsumerImpl`, `ProducerImpl`, `PartitionedConsumerImpl`, and `MultiTopicsConsumerImpl`, we can use atomic `state_` instead of the lock...
Fixes #16449 ### Motivation The add `ackReceiptEnabled` doc is not correct in PR #16465, need to correct the docs. ### Modifications Fix `ackReceiptEnabled` doc. ### Documentation Check the box below...