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

increase partition size, try making performance better

Browse source
This commit is contained in:
Adam 2022-01-21 07:56:36 +01:00
parent 560a5d4172
commit 27776553ba
1 changed files with 2 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

5
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/admin/CreateTopics.kt
View file

@ -2,7 +2,6 @@ package dev.adamko.kafkatorio.admin
import dev.adamko.kafkatorio.events.schema.FactorioObjectData import dev.adamko.kafkatorio.events.schema.FactorioObjectData
import dev.adamko.kafkatorio.events.schema.KafkatorioPacket import dev.adamko.kafkatorio.events.schema.KafkatorioPacket
import dev.adamko.kafkatorio.processor.KafkatorioTopology
import java.util.concurrent.TimeUnit import java.util.concurrent.TimeUnit
import mu.KotlinLogging import mu.KotlinLogging
import org.apache.kafka.clients.admin.Admin import org.apache.kafka.clients.admin.Admin
@ -68,8 +67,8 @@ object CreateTopics {
} }
private fun Admin.createTopics( private fun Admin.createTopics(
numPartitions: Int = 1, numPartitions: Int = 10,
replicationFactor: Short = 1, replicationFactor: Short = 5,
topicNames: () -> Collection<String>, topicNames: () -> Collection<String>,
): CreateTopicsResult = ): CreateTopicsResult =
createTopics(topicNames().distinct().map { createTopics(topicNames().distinct().map {