@@ -897,6 +897,8 @@ void TReadSessionActor::SetupTopicCounters(const TTopicConverterPtr& topic)
897897 topicCounters.Errors = NKikimr::NPQ::TMultiCounter (subGroup, aggr, cons, {" PartitionsErrors" }, true );
898898 topicCounters.Commits = NKikimr::NPQ::TMultiCounter (subGroup, aggr, cons, {" Commits" }, true );
899899 topicCounters.WaitsForData = NKikimr::NPQ::TMultiCounter (subGroup, aggr, cons, {" WaitsForData" }, true );
900+
901+ SetupBytesReadByUserAgentCounter ();
900902}
901903
902904void TReadSessionActor::SetupTopicCounters (const TTopicConverterPtr& topic, const TString& cloudId,
@@ -915,6 +917,8 @@ void TReadSessionActor::SetupTopicCounters(const TTopicConverterPtr& topic, cons
915917 topicCounters.PartitionsInfly = NKikimr::NPQ::TMultiCounter (subGroup, {}, subgroups, {" api.grpc.topic.stream_read.partition_session.count" }, false , " name" );
916918 topicCounters.Errors = NKikimr::NPQ::TMultiCounter (subGroup, {}, subgroups, {" api.grpc.topic.stream_read.partition_session.errors" }, true , " name" );
917919 topicCounters.Commits = NKikimr::NPQ::TMultiCounter (subGroup, {}, subgroups, {" api.grpc.topic.stream_read.commits" }, true , " name" );
920+
921+ SetupBytesReadByUserAgentCounter ();
918922}
919923
920924void TReadSessionActor::Handle (V1::TEvPQProxy::TEvAuthResultOk::TPtr& ev, const TActorContext& ctx) {
0 commit comments