commenting close

streamdal · Mar 14, 2024 · eb7ef21 · eb7ef21
1 parent d613528
commit eb7ef21
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/backends/gcppubsub/relay.go b/backends/gcppubsub/relay.go
@@ -38,7 +38,7 @@ func (g *GCPPubSub) Relay(ctx context.Context, relayOpts *opts.RelayOptions, rel
 	if err != nil {
 		return errors.Wrap(err, "kafka.Relay(): unable to create new streamdal client")
 	}
-	defer sc.Close()
+	// defer sc.Close()
 	// streamdal sdk END
 
 	var m sync.Mutex

diff --git a/backends/kafka/relay.go b/backends/kafka/relay.go
@@ -41,7 +41,7 @@ func (k *Kafka) Relay(ctx context.Context, relayOpts *opts.RelayOptions, relayCh
 	if err != nil {
 		return errors.Wrap(err, "kafka.Relay(): unable to create new streamdal client")
 	}
-	defer sc.Close()
+	// defer sc.Close()
 	// streamdal sdk END
 
 	llog := k.log.WithFields(logrus.Fields{