diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
index 4e9df9a..8506cac 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
@@ -11,7 +11,7 @@ import org.http4k.server.asServer
 
 val appProps = ApplicationProperties()
 
-fun main() = runBlocking<Unit> {
+fun main(): Unit = runBlocking {
 
   CreateTopics.create()
 
diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/webMapTileAggregate.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/webMapTileAggregate.kt
index 7583556..f266978 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/webMapTileAggregate.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/webMapTileAggregate.kt
@@ -110,7 +110,7 @@ fun aggregateWebMapTiles(
           Suppressed.BufferConfig
             .maxRecords(30)
 //            .withMaxBytes(31457280  ) // 30MB
-//            .emitEarlyWhenFull()
+            .emitEarlyWhenFull()
         ).withName("web-map-tile-aggregate-debounce")
       )