diff --git a/lib/cluster/index.ts b/lib/cluster/index.ts
index 5957f049..f673a530 100644
--- a/lib/cluster/index.ts
+++ b/lib/cluster/index.ts
@@ -411,6 +411,10 @@ class Cluster extends EventEmitter {
 
     this.subscriber.stop();
 
+    if (this.options.shardedSubscribers) {
+      this.shardedSubscribers.stop();
+    }
+
     const Promise = PromiseContainer.get();
     if (status === "wait") {
       const ret = asCallback(Promise.resolve<"OK">("OK"), callback);