diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
index a8a3e024..1cb980dc 100644
--- a/roomserver/internal/input/input.go
+++ b/roomserver/internal/input/input.go
@@ -172,11 +172,10 @@ func (r *Inputer) Start() error {
 		func(m *nats.Msg) {
 			roomID := m.Header.Get(jetstream.RoomID)
 			r.startWorkerForRoom(roomID)
-			_ = m.Ack()
 		},
 		nats.HeadersOnly(),
 		nats.DeliverAll(),
-		nats.AckAll(),
+		nats.AckNone(),
 		nats.BindStream(r.InputRoomEventTopic),
 	)
 	return err