writer stats.Retries is a counter now (segmentio/kafka-go#1008)

mostafa · Nov 3, 2022 · f3c80c6 · f3c80c6
1 parent 60c4e1e
commit f3c80c6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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,
 			},
 			{