diff --git a/src/t_stream.c b/src/t_stream.c
index f94f0f60..b20cf125 100644
--- a/src/t_stream.c
+++ b/src/t_stream.c
@@ -1779,6 +1779,10 @@ NULL
             s->last_id = id;
             dbAdd(c->db,c->argv[2],o);
 
+            robj *idarg = createObjectFromStreamID(&id);
+            rewriteClientCommandArgument(c,3,idarg);
+            decrRefCount(idarg);
+
             addReply(c,shared.ok);
             server.dirty++;
             notifyKeyspaceEvent(NOTIFY_STREAM,"xstream-create",