diff options
-rw-r--r-- | ydb/library/persqueue/topic_parser/topic_parser.cpp | 2 | ||||
-rw-r--r-- | ydb/library/persqueue/topic_parser/ut/topic_names_converter_ut.cpp | 6 |
2 files changed, 6 insertions, 2 deletions
diff --git a/ydb/library/persqueue/topic_parser/topic_parser.cpp b/ydb/library/persqueue/topic_parser/topic_parser.cpp index 88c94dcc76..c1377d4d4f 100644 --- a/ydb/library/persqueue/topic_parser/topic_parser.cpp +++ b/ydb/library/persqueue/topic_parser/topic_parser.cpp @@ -206,8 +206,6 @@ void TDiscoveryConverter::BuildForFederation(const TStringBuf& databaseBuf, TStr isRootDb = true; root = PQPrefix; SkipPathPrefix(topicPath, PQPrefix); - } else { - SkipPathPrefix(topicPath, databaseBuf); } } else if (IsPathPrefix(topicPath, PQPrefix)) { isRootDb = true; diff --git a/ydb/library/persqueue/topic_parser/ut/topic_names_converter_ut.cpp b/ydb/library/persqueue/topic_parser/ut/topic_names_converter_ut.cpp index 118c81063b..240f3da2c6 100644 --- a/ydb/library/persqueue/topic_parser/ut/topic_names_converter_ut.cpp +++ b/ydb/library/persqueue/topic_parser/ut/topic_names_converter_ut.cpp @@ -167,6 +167,12 @@ Y_UNIT_TEST_SUITE(DiscoveryConverterTest) { ); UNIT_ASSERT_VALUES_EQUAL(converter->GetFullModernName(), "account-topic"); + converter = converterFactory.MakeDiscoveryConverter( + "account/account/account", {}, "dc1", "account" + ); + UNIT_ASSERT_VALUES_EQUAL(converter->GetFullModernName(), "account/account"); + UNIT_ASSERT_VALUES_EQUAL(converter->GetSecondaryPath("account"), "/account/account/account"); + } Y_UNIT_TEST(FirstClass) { |