diff --git a/test/conformance/helpers/broker_data_plane_test_helper.go b/test/conformance/helpers/broker_data_plane_test_helper.go
index 610a53f1e16..3c0bb15e8d8 100644
--- a/test/conformance/helpers/broker_data_plane_test_helper.go
+++ b/test/conformance/helpers/broker_data_plane_test_helper.go
@@ -332,6 +332,7 @@ func BrokerV1Beta1ConsumerDataPlaneTestHelper(
 			msg,
 		)
 		client.CreatePodOrFail(transformPod, testlib.WithService("transformer-pod"))
+		client.WaitForServiceEndpointsOrFail("transformer-pod", 1)
 		transformTrigger := client.CreateTriggerOrFailV1Beta1(
 			"transform-trigger",
 			resources.WithBrokerV1Beta1(broker.Name),