TakaHiR07 opened a new pull request, #19815:
URL: https://github.com/apache/pulsar/pull/19815
Master Issue: #19814
### Motivation
When server try to dispatch message in
PersistentDispatcherMultipleConsumers, if consumer restart, the entries may
skip filterEntriesForConsumer() and directly go to "No consumers found with
available permits, storing {} positions for later replay".
Then when consumer replay entries, the entries would also skip
filterEntriesForConsumer(), so the aborted txn message would not be filtered.
### Modifications
also filter the aborted txn message in filterEntriesForConsumer() when
readType is replay
### Does this pull request potentially affect one of the following parts:
*If the box was checked, please highlight the changes*
- [ ] Dependencies (add or upgrade a dependency)
- [ ] The public API
- [ ] The schema
- [ ] The default values of configurations
- [ ] The threading model
- [ ] The binary protocol
- [ ] The REST endpoints
- [ ] The admin CLI options
- [ ] The metrics
- [ ] Anything that affects deployment
### Documentation
- [ ] `doc`
- [ ] `doc-required`
- [x] `doc-not-needed`
- [ ] `doc-complete`
### Matching PR in forked repository
PR in forked repository: https://github.com/TakaHiR07/pulsar/pull/2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
