diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py
index 3a67baa2614cffd0eed11d8988c065861acdb371..895a61fbc184a4bd648fa668ea9c33a77f128160 100644
--- a/synapse/storage/stream.py
+++ b/synapse/storage/stream.py
@@ -265,7 +265,7 @@ class StreamStore(SQLBaseStore):
         if rows:
             topo = rows[0]["topological_ordering"]
             toke = rows[0]["stream_ordering"]
-            start_token = "p%s-%s" % (topo, toke)
+            start_token = "t%s-%s" % (topo, toke)
 
             token = (start_token, end_token)
         else: