testUtils.testWithCluster('cluster.xReadGroup', async cluster => {
        const [, readGroupReply] = await Promise.all([
            cluster.xGroupCreate('key', 'group', '$', {
                MKSTREAM: true
            }),