1 reference to MessageSize
Aspire.Confluent.Kafka (1)
MetricsService.cs (1)
48
metrics.MessageSizeMeasurements.Enqueue(new Measurement<long>(statistics.
MessageSize
, tags));