diff --git a/src/t_stream.c b/src/t_stream.c
index 19b20ee56..79265a6fb 100644
--- a/src/t_stream.c
+++ b/src/t_stream.c
@@ -1845,6 +1845,7 @@ NULL
             o = createStreamObject();
             dbAdd(c->db,c->argv[2],o);
             s = o->ptr;
+            signalModifiedKey(c,c->db,c->argv[2]);
         }
 
         streamCG *cg = streamCreateCG(s,grpname,sdslen(grpname),&id);