diff --git a/test/integration/util/util.go b/test/integration/util/util.go
index aa59f6131bc..02b4dadce4e 100644
--- a/test/integration/util/util.go
+++ b/test/integration/util/util.go
@@ -426,8 +426,7 @@ func InitTestSchedulerWithOptions(
 		t.Fatalf("Couldn't create scheduler: %v", err)
 	}
 
-	stopCh := make(chan struct{})
-	eventBroadcaster.StartRecordingToSink(stopCh)
+	eventBroadcaster.StartRecordingToSink(testCtx.Ctx.Done())
 
 	return testCtx
 }