1 write to RxMessageBytes
Aspire.Confluent.Kafka (1)
ConfluentKafkaMetrics.cs (1)
41
RxMessageBytes
= _meter.CreateCounter<long>(Counters.RxMessageBytes, description: Descriptions.RxMessageBytes);
2 references to RxMessageBytes
Aspire.Confluent.Kafka (2)
MetricsService.cs (2)
61
metrics.
RxMessageBytes
.Add(statistics.RxMessageBytes - previous.RxMessageBytes, tags);
72
metrics.
RxMessageBytes
.Add(statistics.RxMessageBytes, tags);