Merge pull request #2512 from kuzzleio/2.27.4-proposal

Release 2.27.4
kuzzleio · Dec 13, 2023 · 4724faa · 4724faa
2 parents c9ab6ef + 2dece99
commit 4724faa
Show file tree

Hide file tree

Showing 4 changed files with 448 additions and 827 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -27,7 +27,6 @@ x-kuzzle-config: &kuzzle-config
     - kuzzle_limits__loginsPerSecond=50
     - NODE_ENV=${NODE_ENV:-development}
     - DEBUG=${DEBUG:-kuzzle:*,-kuzzle:network:protocols:websocket,-kuzzle:events}
-    # - DEBUG=${DEBUG:-none}
     - DEBUG_DEPTH=${DEBUG_DEPTH:-0}
     - DEBUG_MAX_ARRAY_LENGTH=${DEBUG_MAX_ARRAY:-100}
     - DEBUG_EXPAND=${DEBUG_EXPAND:-off}

diff --git a/lib/cluster/node.js b/lib/cluster/node.js
@@ -316,7 +316,7 @@ class ClusterNode {
       global.kuzzle.log.error(error.stack);
     }
 
-    await this.publisher.sendNodeEvicted(this.nodeId, this.nodeId, reason);
+    this.publisher.sendNodeEvicted(this.nodeId, this.nodeId, reason);
 
     this.shutdownNode();
   }
@@ -332,6 +332,9 @@ class ClusterNode {
     const subscriber = this.remoteNodes.get(nodeId);
 
     if (!subscriber) {
+      global.kuzzle.log.warn(
+        `[CLUSTER] Node "${nodeId}" with no subscriber evicted. Reason: ${reason}`,
+      );
       return;
     }
 
@@ -351,7 +354,7 @@ class ClusterNode {
     subscriber.dispose();
 
     if (broadcast) {
-      await this.publisher.sendNodeEvicted(this.nodeId, nodeId, reason);
+      this.publisher.sendNodeEvicted(this.nodeId, nodeId, reason);
     }
 
     if (this.countActiveNodes() < this.config.minimumNodes) {
@@ -477,9 +480,6 @@ class ClusterNode {
         this.shutdownNode();
         return;
       }
-
-      // Rerun the cluster consistency check
-      await this.enforceClusterConsistency();
     } catch (err) {
       global.kuzzle.log.error(
         "[CLUSTER] Unexpected exception caught during a cluster consistency check. Shutting down...",