From 480e2994369de43e3b13019ee9995906d68dd14e Mon Sep 17 00:00:00 2001
From: "zhaozhao.zz" <zhaozhao.zz@alibaba-inc.com>
Date: Tue, 9 Oct 2018 16:22:30 +0800
Subject: [PATCH] Streams: rewrite id in XSTREAM CREATE *

---
 src/t_stream.c | 4 ++++
 1 file changed, 4 insertions(+)

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",