diff --git a/synapse/storage/databases/main/transactions.py b/synapse/storage/databases/main/transactions.py
index c91c44818f3..02ab80b5cd6 100644
--- a/synapse/storage/databases/main/transactions.py
+++ b/synapse/storage/databases/main/transactions.py
@@ -600,6 +600,7 @@ def get_destination_rooms_paginate_txn(
                     start=start,
                     limit=limit,
                     retcols=("room_id", "stream_ordering"),
+                    keyvalues={"destination": destination},
                     order_direction=order,
                 ),
             )