diff --git a/cmd/server/main.go b/cmd/server/main.go
index a85362c..2f05dc2 100644
--- a/cmd/server/main.go
+++ b/cmd/server/main.go
@@ -141,8 +141,8 @@ func main() {
 	}
 	log.Printf("👂 Lausche auf 'game.join' in Queue Group 'game-servers'... (Sub Valid: %v)", sub.IsValid())
 
-	// 4. HANDLER: GAME START (mit Queue Group)
-	_, _ = ec.QueueSubscribe("game.start", "game-servers", func(req *game.StartRequest) {
+	// 4. HANDLER: GAME START (broadcast - alle Pods empfangen, nur der mit dem Raum reagiert)
+	_, _ = ec.Subscribe("game.start", func(req *game.StartRequest) {
 		log.Printf("▶️ START empfangen: RoomID=%s", req.RoomID)
 
 		mu.RLock()
@@ -159,8 +159,8 @@ func main() {
 		}
 	})
 
-	// 5. HANDLER: INPUT (mit Queue Group)
-	_, _ = ec.QueueSubscribe("game.input", "game-servers", func(input *game.ClientInput) {
+	// 5. HANDLER: INPUT (broadcast - alle Pods empfangen, nur der mit dem Spieler reagiert)
+	_, _ = ec.Subscribe("game.input", func(input *game.ClientInput) {
 		mu.RLock()
 		room, ok := playerSessions[input.PlayerID]
 		mu.RUnlock()
diff --git a/k8s/app.yaml b/k8s/app.yaml
index 2e4c372..ea2d8f2 100644
--- a/k8s/app.yaml
+++ b/k8s/app.yaml
@@ -5,7 +5,7 @@ metadata:
   labels:
     app: escape-game
 spec:
-  replicas: 1
+  replicas: 2
   selector:
     matchLabels:
       app: escape-game