Skip to content

Commit 6eb3666

Browse files
committed
fix
1 parent 3497f02 commit 6eb3666

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
@@ -888,8 +888,8 @@ void TPartitionFixture::SendProposeTransactionRequest(ui32 partition,
888888
auto* body = event->Record.MutableData();
889889
auto* operation = body->MutableOperations()->Add();
890890
operation->SetPartitionId(partition);
891-
operation->SetBegin(begin);
892-
operation->SetEnd(end);
891+
operation->SetCommitOffsetsBegin(begin);
892+
operation->SetCommitOffsetsEnd(end);
893893
operation->SetConsumer(client);
894894
operation->SetPath(topic);
895895
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)