bug: incorrect parallel loop usage

ShatteredRealms · Dec 11, 2024 · 2c63bb4 · 2c63bb4
1 parent 4f9eea1
commit 2c63bb4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/bus/bus_kafka_reader.go b/pkg/bus/bus_kafka_reader.go
@@ -116,7 +116,7 @@ func (k *kafkaBusReader[T]) Reset(ctx context.Context) error {
 	log.Logger.WithContext(ctx).WithField("func", "Bus Reset").Infof("Getting offsets for %d partitions", len(partitions))
 	for _, partition := range partitions {
 		wg.Add(1)
-		go func() {
+		go func(partition kafka.Partition) {
 			defer wg.Done()
 			leaderAddr := fmt.Sprintf("%s:%d", partition.Leader.Host, partition.Leader.Port)
 			c, err := kafka.DialLeader(ctx, "tcp", leaderAddr, k.topic, partition.ID)
@@ -139,7 +139,7 @@ func (k *kafkaBusReader[T]) Reset(ctx context.Context) error {
 			offsetMu.Lock()
 			offsets[partition.ID] = offset
 			offsetMu.Unlock()
-		}()
+		}(partition)
 	}
 
 	// Wait for all the offsets to be read