1 reference to MessageSizeMeasurements
Aspire.Confluent.Kafka (1)
ConfluentKafkaMetrics.cs (1)
103
while (
MessageSizeMeasurements
.TryDequeue(out var measurement))