lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

try making performance better...

Browse source
This commit is contained in:
Adam 2022-01-25 00:13:37 +01:00
parent 8645b4552d
commit f5855ba5bd
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
View file

@ -11,7 +11,7 @@ import org.http4k.server.asServer
val appProps = ApplicationProperties()
fun main() = runBlocking<Unit> {
fun main(): Unit = runBlocking {
CreateTopics.create()

2
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/webMapTileAggregate.kt
View file

@ -110,7 +110,7 @@ fun aggregateWebMapTiles(
Suppressed.BufferConfig
.maxRecords(30)
// .withMaxBytes(31457280 ) // 30MB
// .emitEarlyWhenFull()
.emitEarlyWhenFull()
).withName("web-map-tile-aggregate-debounce")
)