2 references to MessageSizeMeasurements
Aspire.Confluent.Kafka (2)
ConfluentKafkaMetrics.cs (1)
103
while (
MessageSizeMeasurements
.TryDequeue(out var measurement))
MetricsService.cs (1)
48
metrics.
MessageSizeMeasurements
.Enqueue(new Measurement<long>(statistics.MessageSize, tags));