diff --git a/backend/pkg/redisstream/consumer.go b/backend/pkg/redisstream/consumer.go
index fed9a7511..228b2c7a0 100644
--- a/backend/pkg/redisstream/consumer.go
+++ b/backend/pkg/redisstream/consumer.go
@@ -102,7 +102,7 @@ func (c *Consumer) ConsumeNext() error {
 				return errors.New("Too many messages per ms in redis")
 			}
 			bID := ts<<13 | (idx & 0x1FFF) // Max: 4096 messages/ms for 69 years
-			c.messageIterator.Iterate([]byte(valueString), messages.NewBatchInfo(sessionID, r.Stream, bID, int64(ts)))
+			c.messageIterator.Iterate([]byte(valueString), messages.NewBatchInfo(sessionID, r.Stream, bID, 0, int64(ts)))
 			if c.autoCommit {
 				if err = c.redis.XAck(r.Stream, c.group, m.ID).Err(); err != nil {
 					return errors.Wrapf(err, "Acknoledgment error for messageID %v", m.ID)