2 references to MessageCountMeasurements
Aspire.Confluent.Kafka (2)
ConfluentKafkaMetrics.cs (1)
95
while (
MessageCountMeasurements
.TryDequeue(out var measurement))
MetricsService.cs (1)
47
metrics.
MessageCountMeasurements
.Enqueue(new Measurement<long>(statistics.MessageCount, tags));