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

rename&move KafkatorioKafkaAdmin.kt

Browse source
This commit is contained in:
Adam 2022-02-13 12:01:12 +01:00
parent 0475d24bcf
commit 6d6429ebac
1 changed files with 1 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

6
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/admin/CreateTopics.kt → modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt
View file

@ -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.FactorioObjectData
import dev.adamko.kafkatorio.events.schema.KafkatorioPacket 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 import org.apache.kafka.clients.admin.TopicListing
//fun main() {
// KafkaAdmin.createKafkatorioTopics()
//}
object KafkatorioKafkaAdmin { object KafkatorioKafkaAdmin {
private val logger = KotlinLogging.logger {} private val logger = KotlinLogging.logger {}