diff options
| author | azevaykin <azevaykin@yandex-team.com> | 2023-08-23 19:25:10 +0300 |
|---|---|---|
| committer | azevaykin <azevaykin@yandex-team.com> | 2023-08-23 20:24:34 +0300 |
| commit | 4a6616e74c1ebb1571d8e1cce45270796b9daa1f (patch) | |
| tree | dc0efea761f4b9272b3e943232df613f2b240065 | |
| parent | ba0e871a8c90ed7abba88cc4036f541f5bee4e4f (diff) | |
| download | ydb-4a6616e74c1ebb1571d8e1cce45270796b9daa1f.tar.gz | |
Increase OffsetToRead in case of new mirror
| -rw-r--r-- | ydb/core/persqueue/mirrorer.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/ydb/core/persqueue/mirrorer.cpp b/ydb/core/persqueue/mirrorer.cpp index 93b12ca496..17bf715b15 100644 --- a/ydb/core/persqueue/mirrorer.cpp +++ b/ydb/core/persqueue/mirrorer.cpp @@ -623,6 +623,8 @@ void TMirrorer::DoProcessNextReaderEvent(const TActorContext& ctx, bool wakeup) ProcessError(ctx, TStringBuilder() << "stream has commit offset more then partition end offset," << "gap will be created [" << OffsetToRead << ";" << createStream->GetCommittedOffset() << ")" ); + + OffsetToRead = createStream->GetCommittedOffset(); } createStream->Confirm(OffsetToRead, createStream->GetCommittedOffset()); |