diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/subscribe/SharedLogsProducer.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/subscribe/SharedLogsProducer.kt
index 64b4b7df..6f51c68b 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/subscribe/SharedLogsProducer.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/subscribe/SharedLogsProducer.kt
@@ -80,7 +80,7 @@ class SharedLogsProducer(
     private fun startSharedStream(matcher: Selector.Matcher) {
         val matcherKey = matcher.describeInternal()
 
-        val logsSink = Sinks.many().multicast().onBackpressureBuffer<LogMessage>()
+        val logsSink = Sinks.many().multicast().onBackpressureBuffer<LogMessage>(4096)
         logsSinks[matcherKey] = logsSink
 
         val sharedStream = produceLogs.produce(connectBlockUpdates.connect(matcher))