diff --git a/test/e2e_new/broker_test.go b/test/e2e_new/broker_test.go index 212c27f6a4..70c5e6ae3b 100644 --- a/test/e2e_new/broker_test.go +++ b/test/e2e_new/broker_test.go @@ -34,6 +34,7 @@ import ( "knative.dev/eventing-kafka-broker/control-plane/pkg/kafka" "knative.dev/eventing-kafka-broker/test/e2e_new/single_partition_config" "knative.dev/eventing-kafka-broker/test/rekt/features" + "knative.dev/eventing/pkg/apis/eventing" "knative.dev/eventing/test/rekt/features/authz" "knative.dev/eventing/test/rekt/features/broker" brokereventingfeatures "knative.dev/eventing/test/rekt/features/broker" @@ -288,7 +289,9 @@ func TestMTChannelBasedBrokerEventTypeAutoCreate(t *testing.T) { env.Prerequisite(ctx, t, features.BrokerCreateConfigMap(configName)) brokerName := feature.MakeRandomK8sName("broker") - env.Prerequisite(ctx, t, broker.GoesReady(brokerName, brokerresources.WithConfig(configName))) + env.Prerequisite(ctx, t, broker.GoesReady(brokerName, + brokerresources.WithConfig(configName), + brokerresources.WithBrokerClass(eventing.MTChannelBrokerClassValue))) env.Test(ctx, t, eventtype_autocreate.AutoCreateEventTypesOnBroker(brokerName)) }