diff --git a/tests/conformance/common.go b/tests/conformance/common.go
index 755325324..6046860ee 100644
--- a/tests/conformance/common.go
+++ b/tests/conformance/common.go
@@ -60,6 +60,7 @@ import (
 const (
 	redis        = "redis"
 	kafka        = "kafka"
+	mqtt         = "mqtt"
 	generateUUID = "$((uuid))"
 )
 
@@ -321,7 +322,7 @@ func loadPubSub(tc TestComponent) pubsub.PubSub {
 		pubsub = p_kafka.NewKafka(testLogger)
 	case "pulsar":
 		pubsub = p_pulsar.NewPulsar(testLogger)
-	case "mqtt":
+	case mqtt:
 		pubsub = p_mqtt.NewMQTTPubSub(testLogger)
 	case "hazelcast":
 		pubsub = p_hazelcast.NewHazelcastPubSub(testLogger)
@@ -386,7 +387,7 @@ func loadOutputBindings(tc TestComponent) bindings.OutputBinding {
 		binding = b_kafka.NewKafka(testLogger)
 	case "http":
 		binding = b_http.NewHTTP(testLogger)
-	case "mqtt":
+	case mqtt:
 		binding = b_mqtt.NewMQTT(testLogger)
 	default:
 		return nil
@@ -407,7 +408,7 @@ func loadInputBindings(tc TestComponent) bindings.InputBinding {
 		binding = b_azure_eventgrid.NewAzureEventGrid(testLogger)
 	case kafka:
 		binding = b_kafka.NewKafka(testLogger)
-	case "mqtt":
+	case mqtt:
 		binding = b_mqtt.NewMQTT(testLogger)
 	default:
 		return nil