From a3fb28edce2fa540709ded7f836913963e2dc9a6 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 878dc747e..e6812c8dc 100644
--- a/src/t_stream.c
+++ b/src/t_stream.c
@@ -1808,6 +1808,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",