Skip to content

Commit b888552

Browse files
Alek5andr-KotovGazizonoki
authored andcommitted
Moved commit "The TEvProposePartitionConfig message is sent only to the main partitions" from ydb repo
1 parent d24417d commit b888552

File tree

1 file changed

+21
-0
lines changed

1 file changed

+21
-0
lines changed

src/client/topic/ut/topic_to_table_ut.cpp

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -211,6 +211,7 @@ void TFixture::SetUp(NUnitTest::TTestContext&)
211211
{
212212
NKikimr::Tests::TServerSettings settings = TTopicSdkTestSetup::MakeServerSettings();
213213
settings.SetEnableTopicServiceTx(true);
214+
settings.SetEnablePQConfigTransactionsAtSchemeShard(true);
214215

215216
Setup = std::make_unique<TTopicSdkTestSetup>(TEST_CASE_NAME, settings);
216217

@@ -2097,6 +2098,26 @@ Y_UNIT_TEST_F(WriteToTopic_Demo_38, TFixture)
20972098
WriteMessagesInTx(0, 1);
20982099
}
20992100

2101+
Y_UNIT_TEST_F(WriteToTopic_Demo_39, TFixture)
2102+
{
2103+
CreateTopic("topic_A", TEST_CONSUMER);
2104+
2105+
NTable::TSession tableSession = CreateTableSession();
2106+
NTable::TTransaction tx = BeginTx(tableSession);
2107+
2108+
WriteToTopic("topic_A", TEST_MESSAGE_GROUP_ID, "message #1", &tx);
2109+
WriteToTopic("topic_A", TEST_MESSAGE_GROUP_ID, "message #2", &tx);
2110+
2111+
WaitForAcks("topic_A", TEST_MESSAGE_GROUP_ID);
2112+
2113+
AddConsumer("topic_A", {"consumer"});
2114+
2115+
CommitTx(tx, EStatus::SUCCESS);
2116+
2117+
auto messages = ReadFromTopic("topic_A", "consumer", TDuration::Seconds(2));
2118+
UNIT_ASSERT_VALUES_EQUAL(messages.size(), 2);
2119+
}
2120+
21002121
Y_UNIT_TEST_F(ReadRuleGeneration, TFixture)
21012122
{
21022123
// There was a server

0 commit comments

Comments
 (0)