Added missing arg

pkg/reconciler/broker/resources/dispatcher.go

@@ -55,6 +55,7 @@ type DispatcherArgs struct {
 	BrokerUrlSecretKey   string
 	BrokerIngressURL     *apis.URL
 	Subscriber           *duckv1.Addressable
+	DLX                  bool
 	Configs              reconcilersource.ConfigAccessor
 	ResourceRequirements corev1.ResourceRequirements
 }
@@ -150,6 +151,13 @@ func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment {
 				Value: *args.Subscriber.CACerts,
 			})
 	}
+	if args.DLX {
+		envs = append(envs,
+			corev1.EnvVar{
+				Name:  "DLX",
+				Value: "true",
+			})
+	}
 	// Default requirements only if none of the requirements are set through annotations
 	if len(args.ResourceRequirements.Limits) == 0 && len(args.ResourceRequirements.Requests) == 0 {
 		// This resource requests and limits comes from performance testing 1500msgs/s with a parallelism of 1000