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

Reply via email to