Making retry behaviour work as expected

twmb · Jan 31, 2025 · ec77273 · ec77273
1 parent f30c518
commit ec77273
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kgo/sink.go b/pkg/kgo/sink.go
@@ -1613,7 +1613,7 @@ func (b *recBatch) maybeFailErr(cfg *cfg) error {
 	switch {
 	case b.isTimedOut(cfg.recordTimeout):
 		return ErrRecordTimeout
-	case b.tries >= cfg.recordRetries:
+	case b.tries > cfg.recordRetries:
 		return ErrRecordRetries
 	case b.owner.cl.producer.isAborting():
 		return ErrAborting