diff --git a/gameyfin/src/main/kotlin/de/grimsi/gameyfin/config/ConfigService.kt b/gameyfin/src/main/kotlin/de/grimsi/gameyfin/config/ConfigService.kt
index 1f1f8ba..45c87df 100644
--- a/gameyfin/src/main/kotlin/de/grimsi/gameyfin/config/ConfigService.kt
+++ b/gameyfin/src/main/kotlin/de/grimsi/gameyfin/config/ConfigService.kt
@@ -19,7 +19,7 @@ class ConfigService(
         private val log = KotlinLogging.logger {}
     }
 
-    private val configUpdates = Sinks.many().multicast().onBackpressureBuffer<ConfigUpdateDto>()
+    private val configUpdates = Sinks.many().multicast().onBackpressureBuffer<ConfigUpdateDto>(1024, false)
 
     fun subscribe(): Flux<ConfigUpdateDto> {
         log.debug { "New subscription for configUpdates (#${configUpdates.currentSubscriberCount()})" }
diff --git a/gameyfin/src/main/kotlin/de/grimsi/gameyfin/core/plugins/PluginService.kt b/gameyfin/src/main/kotlin/de/grimsi/gameyfin/core/plugins/PluginService.kt
index 7ce1d0c..2ec2306 100644
--- a/gameyfin/src/main/kotlin/de/grimsi/gameyfin/core/plugins/PluginService.kt
+++ b/gameyfin/src/main/kotlin/de/grimsi/gameyfin/core/plugins/PluginService.kt
@@ -31,7 +31,7 @@ class PluginService(
         private val log = KotlinLogging.logger {}
     }
 
-    private val pluginUpdates = Sinks.many().multicast().onBackpressureBuffer<PluginUpdateDto>()
+    private val pluginUpdates = Sinks.many().multicast().onBackpressureBuffer<PluginUpdateDto>(1024, false)
     private val pluginConfigValidationCache = mutableMapOf<String, PluginConfigValidationResult>()
 
     init {