diff --git a/operator/builtin/output/forward/forward_test.go b/operator/builtin/output/forward/forward_test.go
index e74fb3892..d7da4c8de 100644
--- a/operator/builtin/output/forward/forward_test.go
+++ b/operator/builtin/output/forward/forward_test.go
@@ -23,6 +23,7 @@ func TestForwardOutput(t *testing.T) {
 		body, _ := ioutil.ReadAll(req.Body)
 		received <- body
 	}))
+	defer srv.Close()
 
 	cfg := NewForwardOutputConfig("test")
 	memoryCfg := buffer.NewMemoryBufferConfig()
@@ -67,6 +68,7 @@ func TestFlushBufferOnClose(t *testing.T) {
 		body, _ := ioutil.ReadAll(req.Body)
 		received <- body
 	}))
+	defer srv.Close()
 
 	cfg.Address = srv.URL
 	ops, err := cfg.Build((testutil.NewBuildContext(t)))