use MT Broker for tests

test/e2e-tests.sh

@@ -37,7 +37,7 @@ fi
 
 # Eventing main config path from HEAD.
 readonly EVENTING_CONFIG="./config/"
-readonly EVENTING_CHANNEL_BROKER_CONFIG="./config/brokers/channel-broker"
+readonly EVENTING_MT_CHANNEL_BROKER_CONFIG="./config/brokers/mt-channel-broker"
 
 # Vendored eventing test iamges.
 readonly VENDOR_EVENTING_TEST_IMAGES="vendor/knative.dev/eventing/test/test_images/"
@@ -84,8 +84,8 @@ function knative_setup() {
     git clone https://github.com/knative/eventing
     cd eventing
     ko apply -f ${EVENTING_CONFIG}
-    # Install Channel Based Broker
-    ko apply -f ${EVENTING_CHANNEL_BROKER_CONFIG}
+    # Install MT Channel Based Broker
+    ko apply -f ${EVENTING_MT_CHANNEL_BROKER_CONFIG}
     popd
   fi
   wait_until_pods_running knative-eventing || fail_test "Knative Eventing did not come up"

test/e2e/broker_channel_flow_test.go

@@ -24,5 +24,5 @@ import (
 )
 
 func TestBrokerChannelFlow(t *testing.T) {
-	helpers.BrokerChannelFlowTestHelper(t, "ChannelBasedBroker" /*brokerClass*/, channelTestRunner)
+	helpers.BrokerChannelFlowTestHelper(t, "MTChannelBasedBroker" /*brokerClass*/, channelTestRunner)
 }

test/e2e/broker_dls_test.go

@@ -31,5 +31,5 @@ func TestBrokerDeadLetterSink(t *testing.T) {
 		{APIVersion: "messaging.knative.dev/v1alpha1", Kind: "KafkaChannel"},
 	}
 
-	helpers.TestBrokerWithConfig(t, "ChannelBasedBroker" /*brokerClass*/, channelTestRunner)
+	helpers.TestBrokerWithConfig(t, "MTChannelBasedBroker" /*brokerClass*/, channelTestRunner)
 }

test/e2e/broker_event_transformation_test.go

@@ -24,5 +24,5 @@ import (
 )
 
 func TestEventTransformationForTrigger(t *testing.T) {
-	helpers.EventTransformationForTriggerTestHelper(t, "ChannelBasedBroker" /*brokerClass*/, channelTestRunner)
+	helpers.EventTransformationForTriggerTestHelper(t, "MTChannelBasedBroker" /*brokerClass*/, channelTestRunner)
 }