pulsar
pulsar copied to clipboard
apache
Apache Pulsar - distributed pub-sub messaging system
### Motivation && Modification There is some mistake in the Failover subscription type. ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 2.7.4 ### Minimal reproduce step class TestPulsarClient(): def test_instance(self): server_url = "pulsar+ssl://xxxxx:xxx/" self._instance...
### Matching PR in forked repository SignorMercurio#3 ### Motivation Docs for Pulsar CLI tools such as `pulsar-admin`, `pulsar-client`, `pulsar` and `pulsar-perf` are auto-generated but contains redundant steps that will produce...
### Motivation Currently, when using entry filters, filtered out messages do not count against the rate limit. Therefore, a subscription that is completely filtered will never be throttled due to...
… default Fixes #17472 ### Motivation `AdditionalServlets.load` does not use the default value of `narExtractionDirectory` when the property is set to an empty string (which is the default in `conf/broker.conf`)....
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version master branch, 8b771a6a528d85bbec6a3d791356a9ab6e9e5ea3 ### Minimal reproduce step start `./pulsar-perf consume -u pulsar://localhost:6650 -m...
With acknowledgmentAtBatchIndexLevelEnabled = false (default) and the Web Socket consumer builder set to builder.enableBatchIndexAcknowledgment(false) (again the default) and all messages acknowledged by the web socket client, we see some messages...
### Motivation doc for https://github.com/apache/pulsar/pull/17041 ### Documentation Check the box below or label this PR directly. Need to update docs? - [ ] `doc-required` (Your PR needs to update docs...
### Motivation Fix metric messagesConsumedCounter calculation error. In the ManagedCursorImpl#setAcknowledgedPosition method, we will calculate skippedEntries based on newMarkDeletePosition and oldMarkDeletePosition, and then accumulate skippedEntries into MSG_CONSUMED_COUNTER_UPDATER: MSG_CONSUMED_COUNTER_UPDATER.addAndGet(this, skippedEntries); But the...
### Motivation Improve integration test coverage https://github.com/apache/pulsar/tree/master/tests/integration The integration test will run on a real cluster, not a mock environment like the unit test does. #### Tools - [ ]...
