diff --git a/src/t_stream.c b/src/t_stream.c
index 37f08572b..daf9509d3 100644
--- a/src/t_stream.c
+++ b/src/t_stream.c
@@ -1559,6 +1559,7 @@ void xackCommand(client *c) {
             raxRemove(nack->consumer->pel,buf,sizeof(buf),NULL);
             streamFreeNACK(nack);
             acknowledged++;
+            server.dirty++;
         }
     }
     addReplyLongLong(c,acknowledged);