diff options
author | Alek5andr-Kotov <akotov@ydb.tech> | 2025-07-04 20:40:37 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2025-07-04 17:40:37 +0000 |
commit | c59858d7f52ea791b46ea7fdb99c663c1044fbff (patch) | |
tree | 41cd81736c8d249662de76450cea75806fbbf005 | |
parent | 3170fe5f46a7d3d6d11961042ac2b831a8a7af6e (diff) | |
download | ydb-main.tar.gz |
-rw-r--r-- | ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp b/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp index 8f356504736..f6aa09ebf0d 100644 --- a/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp +++ b/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp @@ -979,6 +979,9 @@ void TReadSessionActor::Handle(V1::TEvPQProxy::TEvAuthResultOk::TPtr& ev, const for (auto& [name, t] : ev->Get()->TopicAndTablets) { auto& topicHolder = Topics[t.TopicNameConverter->GetInternalName()]; + if (!topicHolder) { + topicHolder = std::make_shared<TTopicHolder>(); + } topicHolder->TabletID = t.TabletID; topicHolder->CloudId = t.CloudId; topicHolder->DbId = t.DbId; |