diff --git a/packages/core-p2p/src/peer-connector.ts b/packages/core-p2p/src/peer-connector.ts
index 5cc8762f64..8f753dee24 100644
--- a/packages/core-p2p/src/peer-connector.ts
+++ b/packages/core-p2p/src/peer-connector.ts
@@ -27,6 +27,7 @@ export class PeerConnector implements P2P.IPeerConnector {
             port: peer.port,
             hostname: peer.ip,
             ackTimeout: Math.max(app.resolveOptions("p2p").getBlocksTimeout, app.resolveOptions("p2p").verifyTimeout),
+            perMessageDeflate: true,
         });
 
         this.connections.set(peer.ip, connection);
diff --git a/packages/core-p2p/src/socket-server/index.ts b/packages/core-p2p/src/socket-server/index.ts
index f37b39ebb9..3d30493e1b 100644
--- a/packages/core-p2p/src/socket-server/index.ts
+++ b/packages/core-p2p/src/socket-server/index.ts
@@ -26,6 +26,7 @@ export const startSocketServer = async (service: P2P.IPeerService, config: Recor
             // See https://github.com/SocketCluster/socketcluster/issues/506 about
             // details on how pingTimeout works.
             pingTimeout: Math.max(app.resolveOptions("p2p").getBlocksTimeout, app.resolveOptions("p2p").verifyTimeout),
+            perMessageDeflate: true,
         },
         ...config.server,
     });