diff --git a/node/src/main/scala/org/bitcoins/node/callback/NodeCallbackStreamManager.scala b/node/src/main/scala/org/bitcoins/node/callback/NodeCallbackStreamManager.scala
index cbc9766fdd..75d8ea4f9d 100644
--- a/node/src/main/scala/org/bitcoins/node/callback/NodeCallbackStreamManager.scala
+++ b/node/src/main/scala/org/bitcoins/node/callback/NodeCallbackStreamManager.scala
@@ -20,7 +20,7 @@ import scala.concurrent.{ExecutionContext, Future}
 case class NodeCallbackStreamManager(
     callbacks: NodeCallbacks,
     overflowStrategy: OverflowStrategy = OverflowStrategy.backpressure,
-    maxBufferSize: Int = 1000)(implicit system: ActorSystem)
+    maxBufferSize: Int = 32)(implicit system: ActorSystem)
     extends NodeCallbacks
     with StartStopAsync[Unit]
     with Logging {