Skip to content

Commit 8615506

Browse files
committed
fix
1 parent fc7860a commit 8615506

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

ydb/core/persqueue/ut/partition_ut.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -954,8 +954,8 @@ void TPartitionFixture::SendProposeTransactionRequest(ui32 partition,
954954
auto* body = event->Record.MutableData();
955955
auto* operation = body->MutableOperations()->Add();
956956
operation->SetPartitionId(partition);
957-
operation->SetBegin(begin);
958-
operation->SetEnd(end);
957+
operation->SetCommitOffsetsBegin(begin);
958+
operation->SetCommitOffsetsEnd(end);
959959
operation->SetConsumer(client);
960960
operation->SetPath(topic);
961961
body->SetImmediate(immediate);

ydb/core/persqueue/ut/user_action_processor_ut.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -653,8 +653,8 @@ void TUserActionProcessorFixture::SendProposeTransactionRequest(ui32 partition,
653653
auto* body = event->Record.MutableTxBody();
654654
auto* operation = body->MutableOperations()->Add();
655655
operation->SetPartitionId(partition);
656-
operation->SetBegin(begin);
657-
operation->SetEnd(end);
656+
operation->SetCommitOffsetsBegin(begin);
657+
operation->SetCommitOffsetsEnd(end);
658658
operation->SetConsumer(client);
659659
operation->SetPath(topic);
660660
body->SetImmediate(immediate);

0 commit comments

Comments
 (0)