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 06bf03904dee..d5856e5b36f7 100644 --- a/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp +++ b/ydb/services/deprecated/persqueue_v0/grpc_pq_read_actor.cpp @@ -839,7 +839,7 @@ void TReadSessionActor::RegisterSessions(const TActorContext& ctx) { } void TReadSessionActor::SetupBytesReadByUserAgentCounter() { - BytesReadByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents") + BytesReadByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents", false) ->GetSubgroup("host", "") ->GetSubgroup("protocol", "pqv0") ->GetSubgroup("consumer", ClientPath) diff --git a/ydb/services/deprecated/persqueue_v0/grpc_pq_write_actor.cpp b/ydb/services/deprecated/persqueue_v0/grpc_pq_write_actor.cpp index 86b887038be4..ccdef2238730 100644 --- a/ydb/services/deprecated/persqueue_v0/grpc_pq_write_actor.cpp +++ b/ydb/services/deprecated/persqueue_v0/grpc_pq_write_actor.cpp @@ -258,7 +258,7 @@ void TWriteSessionActor::InitAfterDiscovery(const TActorContext& ctx) { void TWriteSessionActor::SetupBytesWrittenByUserAgentCounter() { - BytesWrittenByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents") + BytesWrittenByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents", false) ->GetSubgroup("host", "") ->GetSubgroup("protocol", "pqv0") ->GetSubgroup("topic", FullConverter->GetFederationPath()) diff --git a/ydb/services/persqueue_v1/actors/read_session_actor.cpp b/ydb/services/persqueue_v1/actors/read_session_actor.cpp index 272349f9655a..91b132470b29 100644 --- a/ydb/services/persqueue_v1/actors/read_session_actor.cpp +++ b/ydb/services/persqueue_v1/actors/read_session_actor.cpp @@ -894,7 +894,7 @@ void TReadSessionActor::Handle(typename TEvReadInit::TPtr& template void TReadSessionActor::SetupBytesReadByUserAgentCounter() { static constexpr auto protocol = UseMigrationProtocol ? "pqv1" : "topic"; - BytesReadByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents") + BytesReadByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents", false) ->GetSubgroup("host", "") ->GetSubgroup("protocol", protocol) ->GetSubgroup("consumer", ClientPath) diff --git a/ydb/services/persqueue_v1/actors/write_session_actor.cpp b/ydb/services/persqueue_v1/actors/write_session_actor.cpp index 5c0fa5671c45..6b414c0c551c 100644 --- a/ydb/services/persqueue_v1/actors/write_session_actor.cpp +++ b/ydb/services/persqueue_v1/actors/write_session_actor.cpp @@ -497,7 +497,7 @@ void TWriteSessionActor::InitAfterDiscovery(const TActorCo template void TWriteSessionActor::SetupBytesWrittenByUserAgentCounter(const TString& topicPath) { static constexpr auto protocol = UseMigrationProtocol ? "pqv1" : "topic"; - BytesWrittenByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents") + BytesWrittenByUserAgent = GetServiceCounters(Counters, "pqproxy|userAgents", false) ->GetSubgroup("host", "") ->GetSubgroup("protocol", protocol) ->GetSubgroup("topic", topicPath)