diff --git a/pkg/pipeline/builder/stream.go b/pkg/pipeline/builder/stream.go
index 7179e064..4fe891d5 100644
--- a/pkg/pipeline/builder/stream.go
+++ b/pkg/pipeline/builder/stream.go
@@ -132,9 +132,6 @@ func (sb *StreamBin) AddStream(url string) error {
 		if err = sink.Set("location", url); err != nil {
 			return errors.ErrGstPipelineError(err)
 		}
-		if err = sink.SetProperty("async-connect", false); err != nil {
-			return errors.ErrGstPipelineError(err)
-		}
 
 	case types.OutputTypeSRT:
 		sink, err = gst.NewElementWithName("srtsink", fmt.Sprintf("srtsink_%s", name))