This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.wiki.git
The following commit(s) were added to refs/heads/master by this push:
new 1d979a5 Updated PIP 54: Support acknowledgment at batch index level
(markdown)
1d979a5 is described below
commit 1d979a5463a3fa5944b82e45ea4fb9355be9ea70
Author: lipenghui <[email protected]>
AuthorDate: Tue Feb 18 17:57:37 2020 +0800
Updated PIP 54: Support acknowledgment at batch index level (markdown)
---
...-Support-acknowledgment-at-batch-index-level.md | 33 +++++++++-------------
1 file changed, 13 insertions(+), 20 deletions(-)
diff --git a/PIP-54:-Support-acknowledgment-at-batch-index-level.md
b/PIP-54:-Support-acknowledgment-at-batch-index-level.md
index 1b35fdb..e3769d5 100644
--- a/PIP-54:-Support-acknowledgment-at-batch-index-level.md
+++ b/PIP-54:-Support-acknowledgment-at-batch-index-level.md
@@ -29,38 +29,31 @@ For save resources, transfer the acked batch indexes ranges
between client and b
### Wire protocol
```proto
-message BatchMessageIndexesAckData {
- required MessageIdData message_id = 1;
- required int32 batchSize = 2;
- repeated IntRange ack_indexes = 3;
-}
-```
-
-```proto
message CommandMessage {
- repeated IntRange acked_indexes = 4;
+ repeated int64 ack_set = 4;
}
```
```proto
-
-message CommandAck {
- repeated BatchMessageIndexesAckData batch_message_ack_indexes = 8;
+message MessageIdData {
+ repeated int64 ack_set = 5;
}
```
### Managed ledger data formats
```proto
-message BatchDeletedIndexRange {
- required uint32 lowerIndex = 1;
- required uint32 upperIndex = 2;
+message BatchedEntryDeletionIndexInfo {
+ required NestedPositionInfo position = 1;
+ repeated int64 deleteSet = 2;
}
+```
-message BatchDeletedIndexInfo {
- required NestedPositionInfo position = 1;
- repeated BatchDeletedIndexRange batchDeletedIndexes = 2;
+```proto
+message ManagedCursorInfo {
+ // Store which index in the batch message has been deleted
+ repeated BatchedEntryDeletionIndexInfo batchedEntryDeletionIndexInfo = 7;
}
```
@@ -68,9 +61,9 @@ message BatchDeletedIndexInfo {
message PositionInfo {
// Store which index in the batch message has been deleted
- repeated BatchDeletedIndexInfo batchDeletedIndexes = 5;
+ repeated BatchedEntryDeletionIndexInfo batchedEntryDeletionIndexInfo = 5;
}
```
## Configuration
-Added a flag named `batchIndexAcknowledgeEnable` in broker.conf to enable or
disable the batch index acknowledgement
\ No newline at end of file
+Added a flag named `acknowledgmentAtBatchIndexLevelEnabled` in broker.conf to
enable or disable the batch index acknowledgement
\ No newline at end of file