pulsar

pulsar copied to clipboard

### Motivation This PR fixes the link to the Debezium MS SQL integration tests in the docs. ### Modifications Updated master + 2.10 docs ### Verifying this change - [...

alpreu

[fix][broker] Fix the markdelete position does not move forward when isAutoSkipNonRecoverableData=true and individual ack

38

### Motivation When isAutoSkipNonRecoverableData=true and individual ack, the markdelete position does not move forward. https://github.com/apache/pulsar/blob/72dd01b8a0339541a8c3e75070bf6b8c2e6d0906/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java#L100-L114 ### Modifications 1. Add a skipped variable in EntryImpl to record whether the entry is...

lordcheng10

### Motivation Variable policiesCache in NamespaceBundleFactory is not used. ### Documentation - [ ] `doc-required` (Your PR needs to update docs and you will update later) - [x] `doc-not-needed` (Please...

lordcheng10

Not enough non-faulty bookies available

15

apache-pulsar-2.8.0 three pulsar cluster second pulsar messages: 16:33:15.772 [BookKeeperClientWorker-OrderedExecutor-0-0] WARN org.apache.bookkeeper.client.PendingAddOp - Failed to write entry (135, 0): Bookie handle is not available 16:33:15.801 [BookKeeperClientWorker-OrderedExecutor-0-0] ERROR org.apache.bookkeeper.client.MetadataUpdateLoop - UpdateLoop(ledgerId=135,loopId=413ab672) Exception...

yunfeng79

Check create topic permission on topic creation using pulsar proto clients

19

Fixes #17406 ### Motivation Enable CREATE_TOPIC permission check on topic auto creation. ### Modifications Introduce AuthAction.create_topic for the PulsarAuthorizationProvider ### Verifying this change - [ ] Make sure that the...

KannarFr

[improve][CI] Generate unit test code coverage reports and upload to Codecov

16

### Motivation Add code coverage to make sure good quality of PRs. Although unit tests run in different runners, by using [Codecov](https://docs.codecov.com/docs) the coverage XML reports can be aggregated automately....

yaalsn

[improve][cpp] Support acknowledging a list of messages

2

### Motivation https://github.com/apache/pulsar/issues/17428 ### Modifications - Add acknowledge message id list API. ### Documentation - [ ] `doc-required` (Your PR needs to update docs and you will update later) -...

shibd

[bugfix] ManagedLedger: move to FENCED state in case of BadVersionException

4

### Motivation It may happen that a ManagedLedger continues to work even in case of seeing a BadVersionException. For instance background activities like trimming ledgers, or offloading will continue to...

eolivelli

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version Pulsar version: 2.10.1 ### Minimal reproduce step Follow [Pulsar functions quickstart](https://github.com/apache/pulsar/blob/master/site2/website/versioned_docs/version-2.3.0/functions-quickstart.md#writing-and-running-a-new-function). I'm using...

dionjansen

Make BookieId work with PulsarRegistrationDriver

1

### Motivation In Pulsar 2.10 the custom "BookieId" feature doesn't work anymore because in PulsarRegistrationDriver we are not implementing `getBookieServiceInfo` ### Modifications Implement `getBookieServiceInfo` ### Verifying this change This change...

eolivelli