From f5855ba5bdc5fc176d33bd288da4631e90c3ffd3 Mon Sep 17 00:00:00 2001
From: Adam <897017+aSemy@users.noreply.github.com>
Date: Tue, 25 Jan 2022 00:13:37 +0100
Subject: [PATCH] try making performance better...

---
 .../kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt    | 2 +-
 .../adamko/kafkatorio/processor/topology/webMapTileAggregate.kt | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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")
       )