diff --git a/writer.go b/writer.go index 2d1b6c1..2d040bd 100644 --- a/writer.go +++ b/writer.go @@ -339,7 +339,7 @@ func (k *Kafka) reportWriterStats(currentStats kafkago.WriterStats) { Metric: k.metrics.WriterRetries, Tags: sampleTags, }, - Value: float64(currentStats.Retries.Avg), + Value: float64(currentStats.Retries), Metadata: ctm.Metadata, }, {