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/processor/admin/KafkatorioKafkaAdmin.kt similarity index 96% rename from modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/admin/CreateTopics.kt rename to modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt index 3f578e1..107c411 100644 --- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/admin/CreateTopics.kt +++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt @@ -1,4 +1,4 @@ -package dev.adamko.kafkatorio.admin +package dev.adamko.kafkatorio.processor.admin import dev.adamko.kafkatorio.events.schema.FactorioObjectData import dev.adamko.kafkatorio.events.schema.KafkatorioPacket @@ -11,10 +11,6 @@ import org.apache.kafka.clients.admin.NewTopic import org.apache.kafka.clients.admin.TopicListing -//fun main() { -// KafkaAdmin.createKafkatorioTopics() -//} - object KafkatorioKafkaAdmin { private val logger = KotlinLogging.logger {}