Thank you very much, I will add these points to the document
1
Now the persistence of ack is also asynchronous, not every ack will be
persisted immediately, and the lost part will be re-consumed.
When the entry is successfully written but the marker fails to be written,
we will consider the whole t
We can look at ManagedCursorImpl.buildIndividualDeletedMessageRanges
What is saved in the entry is not a bitSet, but a messageRange one by one,
which contains information such as ledgerId and entryId. BitSet only exists
in the memory and is used to quickly determine whether it already exists.
In a
Thanks for the validation.
Add my own +1
- verified start standalone and produce/consume messages
- verified functions/state functions
java version: 1.8.0_241
Close this vote with 3 +1(binding), 2 +1(non-binding)
I will start the subsequent release work soon
Thanks,
- Penghui
Jia Zhai δΊ2021
tschmidt64-SC commented on issue #134:
URL:
https://github.com/apache/pulsar-client-node/issues/134#issuecomment-763964768
I'm getting this same issue on MacOS (Big Sur 11.1).
```bash
β β brew reinstall libpulsar
==> Downloading
https://homebrew.bintray.com/bottles/libpulsa
Jennifer88huang commented on pull request #95:
URL: https://github.com/apache/pulsar-helm-chart/pull/95#issuecomment-764215222
@yufan022 thank you very much for your contribution.
This is an automated message from the Apache