From d992e09135b7948f4f202e36418f4ce4afbb67d6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lovro=20Ma=C5=BEgon?= <lovro.mazgon@gmail.com>
Date: Tue, 9 Apr 2024 17:15:32 +0200
Subject: [PATCH] fix ineffassign

---
 destination/franz.go | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/destination/franz.go b/destination/franz.go
index 0af529c..deedc13 100644
--- a/destination/franz.go
+++ b/destination/franz.go
@@ -108,18 +108,18 @@ func (p *FranzProducer) Produce(ctx context.Context, records []sdk.Record) (int,
 	}
 
 	var (
-		wg       csync.WaitGroup
-		results  = make([]error, 0, len(records))
-		errIndex = -1
-		err      error
-		rec      *kgo.Record
+		wg              csync.WaitGroup
+		results         = make([]error, 0, len(records))
+		rec             *kgo.Record
+		prepareErr      error
+		prepareErrIndex = -1
 	)
 
 	for i, r := range records {
-		rec, err = p.prepareRecord(r)
-		if err != nil {
-			errIndex = i
-			err = fmt.Errorf("failed to prepare record: %w", err)
+		rec, prepareErr = p.prepareRecord(r)
+		if prepareErr != nil {
+			prepareErrIndex = i
+			prepareErr = fmt.Errorf("failed to prepare record: %w", prepareErr)
 			break
 		}
 
@@ -134,7 +134,7 @@ func (p *FranzProducer) Produce(ctx context.Context, records []sdk.Record) (int,
 		)
 	}
 
-	err = wg.Wait(ctx)
+	err := wg.Wait(ctx)
 	if err != nil {
 		return 0, fmt.Errorf("failed to wait for all records to be produced: %w", err)
 	}
@@ -145,10 +145,10 @@ func (p *FranzProducer) Produce(ctx context.Context, records []sdk.Record) (int,
 		}
 	}
 
-	if err != nil {
+	if prepareErr != nil {
 		// We failed to prepare a record, return the error and the index of the
 		// record that failed.
-		return errIndex, err
+		return prepareErrIndex, prepareErr
 	}
 
 	return len(results), nil