We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 19cdeda commit f1271f9Copy full SHA for f1271f9
ydb/core/persqueue/ut/ut_with_sdk/topic_ut.cpp
@@ -456,13 +456,16 @@ Y_UNIT_TEST_SUITE(WithSDK) {
456
setup.Write("message-1-2", 1);
457
} else if (x.GetPartitionSession()->GetPartitionId() == 1 && m.GetOffset() == 0) {
458
m.Commit();
459
+ return false;
460
}
461
- return false;
462
+
463
+ return true;
464
});
465
- Sleep(TDuration::Seconds(2));
466
+ Sleep(TDuration::Seconds(3));
467
468
+ // Commit hasn`t applyed because messages from the parent partitions has`t been committed
469
UNIT_ASSERT_VALUES_EQUAL(0, getCommittedOffset(0));
470
UNIT_ASSERT_VALUES_EQUAL(0, getCommittedOffset(1));
471
UNIT_ASSERT_VALUES_EQUAL(0, getCommittedOffset(2));
0 commit comments