@@ -897,6 +897,8 @@ void TReadSessionActor::SetupTopicCounters(const TTopicConverterPtr& topic)
897
897
topicCounters.Errors = NKikimr::NPQ::TMultiCounter (subGroup, aggr, cons, {" PartitionsErrors" }, true );
898
898
topicCounters.Commits = NKikimr::NPQ::TMultiCounter (subGroup, aggr, cons, {" Commits" }, true );
899
899
topicCounters.WaitsForData = NKikimr::NPQ::TMultiCounter (subGroup, aggr, cons, {" WaitsForData" }, true );
900
+
901
+ SetupBytesReadByUserAgentCounter ();
900
902
}
901
903
902
904
void TReadSessionActor::SetupTopicCounters (const TTopicConverterPtr& topic, const TString& cloudId,
@@ -915,6 +917,8 @@ void TReadSessionActor::SetupTopicCounters(const TTopicConverterPtr& topic, cons
915
917
topicCounters.PartitionsInfly = NKikimr::NPQ::TMultiCounter (subGroup, {}, subgroups, {" api.grpc.topic.stream_read.partition_session.count" }, false , " name" );
916
918
topicCounters.Errors = NKikimr::NPQ::TMultiCounter (subGroup, {}, subgroups, {" api.grpc.topic.stream_read.partition_session.errors" }, true , " name" );
917
919
topicCounters.Commits = NKikimr::NPQ::TMultiCounter (subGroup, {}, subgroups, {" api.grpc.topic.stream_read.commits" }, true , " name" );
920
+
921
+ SetupBytesReadByUserAgentCounter ();
918
922
}
919
923
920
924
void TReadSessionActor::Handle (V1::TEvPQProxy::TEvAuthResultOk::TPtr& ev, const TActorContext& ctx) {
0 commit comments