From 27776553ba3eb8f979deedd38609e74af2150f66 Mon Sep 17 00:00:00 2001
From: Adam <897017+aSemy@users.noreply.github.com>
Date: Fri, 21 Jan 2022 07:56:36 +0100
Subject: [PATCH] increase partition size, try making performance better

---
 .../main/kotlin/dev/adamko/kafkatorio/admin/CreateTopics.kt  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/admin/CreateTopics.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/admin/CreateTopics.kt
index 3d07c2e..845a7c3 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/admin/CreateTopics.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/admin/CreateTopics.kt
@@ -2,7 +2,6 @@ package dev.adamko.kafkatorio.admin
 
 import dev.adamko.kafkatorio.events.schema.FactorioObjectData
 import dev.adamko.kafkatorio.events.schema.KafkatorioPacket
-import dev.adamko.kafkatorio.processor.KafkatorioTopology
 import java.util.concurrent.TimeUnit
 import mu.KotlinLogging
 import org.apache.kafka.clients.admin.Admin
@@ -68,8 +67,8 @@ object CreateTopics {
   }
 
   private fun Admin.createTopics(
-    numPartitions: Int = 1,
-    replicationFactor: Short = 1,
+    numPartitions: Int = 10,
+    replicationFactor: Short = 5,
     topicNames: () -> Collection<String>,
   ): CreateTopicsResult =
     createTopics(topicNames().distinct().map {