From f3c80c6ef9a358df70d3fc23e0d7465fd45bcc63 Mon Sep 17 00:00:00 2001 From: Mostafa Moradian Date: Thu, 3 Nov 2022 14:05:53 +0100 Subject: [PATCH] writer stats.Retries is a counter now (https://github.com/segmentio/kafka-go/pull/1008) --- writer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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, }, {