remove redundant error check

ConduitIO · Nov 2, 2023 · b278cb9 · b278cb9
1 parent 21c1ede
commit b278cb9
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/source/franz.go b/source/franz.go
@@ -52,11 +52,6 @@ func NewFranzConsumer(ctx context.Context, cfg Config) (*FranzConsumer, error) {
 		return nil, fmt.Errorf("failed to create kafka client: %w", err)
 	}
 
-	if err != nil {
-		cl.Close()
-		return nil, err
-	}
-
 	return &FranzConsumer{
 		client: cl,
 		acker:  newBatchAcker(cl, 1000),