rdhabalia opened a new pull request #14282:
URL: https://github.com/apache/pulsar/pull/14282
### Motivation
Pulsar replicator fails to delete messages sometimes which creates ack-hole
for replicator and causes huge backlog if it's not taken care soon. Therefore,
broker should handle such failure of acknowledged message and avoid creating
any ack-hole of the replicator's cursor.
```
./pulsar-admin persistent stats-internal persistent://prop/global/ns/t1
{
:
"lastConfirmedEntry" : "621807735:29501",
"state" : "LedgerOpened",
"ledgers" : [ {
"ledgerId" : 615666239,
"entries" : 50000,
"size" : 20897862,
"offloaded" : false
}, {
"ledgerId" : 615672180,
"entries" : 50000,
"size" : 20846027,
"offloaded" : false
}:
:
:
], "cursors" : {
"us-west1" : {
"markDeletePosition" : "615666239:14710",
"readPosition" : "621807735:29502",
"individuallyDeletedMessages" : "[(615666239:15073..621807735:29501]]",
"state" : "Open",
"numberOfEntriesSinceFirstNotAckedMessage" : 104117591,
"totalNonContiguousDeletedMessagesRange" : 1,
"properties" : { }
},
"us-east1" : {
"markDeletePosition" : "616189378:46815",
"readPosition" : "621807735:29502",
"individuallyDeletedMessages" : "[(616189378:48037..621807735:29501]]",
"state" : "Open",
"numberOfEntriesSinceFirstNotAckedMessage" : 96735486,
"totalNonContiguousDeletedMessagesRange" : 1,
"properties" : { }
}
```
### Modification
Retry failure in replicator-acking to avoid backlog.
--
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]
