diff options
| author | komels <[email protected]> | 2023-08-16 10:22:12 +0300 |
|---|---|---|
| committer | komels <[email protected]> | 2023-08-16 11:06:59 +0300 |
| commit | 49a1c02a28a2fb37e642489f57f73b4a8d7cac03 (patch) | |
| tree | c8971e3047a8ef38f56f8f0587bf6c3cf4b5c96b | |
| parent | bfed16277198fab0e7f6411fbe2d16c07214248a (diff) | |
Add commit offset to mirrored Lock ack
| -rw-r--r-- | ydb/core/persqueue/mirrorer.cpp | 2 |
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(); |
