diff --git a/index.js b/index.js
index 4c2c4e2..187cda7 100644
--- a/index.js
+++ b/index.js
@@ -16,8 +16,6 @@ redis.quit = async () => {
 }
 
 redis.ensureGroup = async (stream, group) => {
-    await redis.connect();
-
     try {
         await redis.client.xGroupCreate(stream, group, "0", {MKSTREAM: true});