baomingyu opened a new pull request #10096:
URL: https://github.com/apache/pulsar/pull/10096
Fixes #8115
Master Issue: #8115
### Motivation
first point:
Sometimes it will not success to call this method and the method
readMoreEntries will not be called
` if (future.isSuccess() && keyNumbers.decrementAndGet() == 0) {
readMoreEntries();
} `
second point:
Sometimes keyNumbers will not be decrement to zero , and broker will not
be start next loop to readMoreEntries.
some partition topic will be stunk and stop to push message to consumer
,even though there is permits in consumers.
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
