summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorkomels <[email protected]>2023-08-16 10:22:12 +0300
committerkomels <[email protected]>2023-08-16 11:06:59 +0300
commit49a1c02a28a2fb37e642489f57f73b4a8d7cac03 (patch)
treec8971e3047a8ef38f56f8f0587bf6c3cf4b5c96b
parentbfed16277198fab0e7f6411fbe2d16c07214248a (diff)
Add commit offset to mirrored Lock ack
-rw-r--r--ydb/core/persqueue/mirrorer.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/persqueue/mirrorer.cpp b/ydb/core/persqueue/mirrorer.cpp
index a5e4d3d81d5..93b12ca4963 100644
--- a/ydb/core/persqueue/mirrorer.cpp
+++ b/ydb/core/persqueue/mirrorer.cpp
@@ -625,7 +625,7 @@ void TMirrorer::DoProcessNextReaderEvent(const TActorContext& ctx, bool wakeup)
);
}
- createStream->Confirm(OffsetToRead);
+ createStream->Confirm(OffsetToRead, createStream->GetCommittedOffset());
RequestSourcePartitionStatus();
} else if (auto* destroyStream = std::get_if<TPersQueueReadEvent::TStopPartitionSessionEvent>(&event.GetRef())) {
destroyStream->Confirm();