diff --git a/event_proxy/main.go b/event_proxy/main.go
index 2f3c44a..050cb2e 100644
--- a/event_proxy/main.go
+++ b/event_proxy/main.go
@@ -26,13 +26,22 @@ func getMQTTClient() mqtt.Client {
 	if mqttPort == "" {
 		panic("MQTT_PORT environment variable not set")
 	}
+	mqttUsername := os.Getenv("MQTT_USERNAME")
+	if mqttUsername == "" {
+		panic("MQTT_USERNAME environment variable not set")
+	}
+	mqttPassword := os.Getenv("MQTT_PASSWORD")
+	if mqttPassword == "" {
+		panic("MQTT_PASSWORD environment variable not set")
+	}
 
 	brokerURL := "tcp://" + mqttHost + ":" + mqttPort
 	slog.Info("Connecting to MQTT", "broker", brokerURL)
-
 	opts := mqtt.NewClientOptions().
 		AddBroker(brokerURL).
-		SetClientID("event-proxy")
+		SetClientID("event-proxy").
+		SetUsername(mqttUsername).
+		SetPassword(mqttPassword)
 
 	client := mqtt.NewClient(opts)