From 3cae5f032105125855849a8aae3d3e2fc6872579 Mon Sep 17 00:00:00 2001
From: antirez <antirez@gmail.com>
Date: Tue, 20 Mar 2018 11:06:50 +0100
Subject: [PATCH] CG: XGROUP CREATE/DELCONUSMER replication.

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

diff --git a/src/t_stream.c b/src/t_stream.c
index 44b4912f..d2afa6a7 100644
--- a/src/t_stream.c
+++ b/src/t_stream.c
@@ -1496,6 +1496,7 @@ NULL
         streamCG *cg = streamCreateCG(s,grpname,sdslen(grpname),&id);
         if (cg) {
             addReply(c,shared.ok);
+            server.dirty++;
         } else {
             addReplySds(c,
                 sdsnew("-BUSYGROUP Consumer Group name already exists\r\n"));
@@ -1507,6 +1508,7 @@ NULL
          * that were yet associated with such a consumer. */
         long long pending = streamDelConsumer(cg,c->argv[4]->ptr);
         addReplyLongLong(c,pending);
+        server.dirty++;
     } else if (!strcasecmp(opt,"HELP")) {
         addReplyHelp(c, help);
     } else {