fix use not uninitialized value

1 files changed, 18 insertions, 4 deletions

diff --git a/ydb/core/kafka_proxy/kafka_metrics.cpp b/ydb/core/kafka_proxy/kafka_metrics.cpp
index 758f128d7bc..c09a9790299 100644
--- a/ydb/core/kafka_proxy/kafka_metrics.cpp
+++ b/ydb/core/kafka_proxy/kafka_metrics.cpp
@@ -4,10 +4,24 @@
 namespace NKafka {
 
 TVector<std::pair<TString, TString>> BuildLabels(const NKafka::TContext::TPtr context, const TString& method, const TString& topic, const TString& name, const TString& errorCode) {
-    return {{"counters", context->IsServerless ? "datastreams_serverless" : "datastreams"},
-            {"database", context->DatabasePath}, {"method", method}, {"cloud_id", context->CloudId},
-            {"folder_id", context->FolderId}, {"database_id", context->DatabaseId},
-            {"topic", topic}, {"error_code", errorCode}, {"name", name}};
+    if (context->Authenticated()) {
+        return {{"counters", context->IsServerless ? "datastreams_serverless" : "datastreams"},
+                {"database", context->DatabasePath},
+                {"method", method},
+                {"cloud_id", context->CloudId},
+                {"folder_id", context->FolderId},
+                {"database_id", context->DatabaseId},
+                {"topic", topic},
+                {"error_code", errorCode},
+                {"name", name}};
+    } else {
+        return {{"counters", "datastreams"},
+                {"method", method},
+                {"topic", topic},
+                {"error_code", errorCode},
+                {"name", name}};
+
+    }
 }
 
 TActorId MakeKafkaMetricsServiceID() {