diff --git a/node/pkg/p2p/p2p.go b/node/pkg/p2p/p2p.go
index d6a5f6e260..92a5925494 100644
--- a/node/pkg/p2p/p2p.go
+++ b/node/pkg/p2p/p2p.go
@@ -248,7 +248,9 @@ func Run(
 			return fmt.Errorf("failed to join topic: %w", err)
 		}
 
-		sub, err := th.Subscribe()
+		// Increase the buffer size to prevent failed delivery
+		// to slower subscribers
+		sub, err := th.Subscribe(pubsub.WithBufferSize(1024))
 		if err != nil {
 			return fmt.Errorf("failed to subscribe topic: %w", err)
 		}