@@ -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+
21002121Y_UNIT_TEST_F (ReadRuleGeneration, TFixture)
21012122{
21022123 // There was a server
0 commit comments