diff --git a/modules/events-server/build.gradle.kts b/modules/events-server/build.gradle.kts
index ed4964e..f1e7b8c 100644
--- a/modules/events-server/build.gradle.kts
+++ b/modules/events-server/build.gradle.kts
@@ -38,7 +38,7 @@ dependencies {
 }
 
 application {
-  mainClass.set("dev.adamko.factorioevents.processor.mainKt")
+  mainClass.set("dev.adamko.kafkatorio.processor.EventProcessorKt")
 }
 
 tasks.withType<KotlinCompile> {
diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/FactorioEventsTopology.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt
similarity index 98%
rename from modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/FactorioEventsTopology.kt
rename to modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt
index 139bf1b..523b291 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/FactorioEventsTopology.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt
@@ -13,7 +13,7 @@ import org.apache.kafka.streams.TopologyDescription
 import org.apache.kafka.streams.kstream.Consumed
 import org.apache.kafka.streams.kstream.Produced
 
-class FactorioEventsTopology(
+class KafkatorioTopology(
   private val websocketServer: WebsocketServer,
   private val builder: StreamsBuilder = StreamsBuilder(),
 ) {
diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
index 0011293..499cb63 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/eventProcessor.kt
@@ -12,7 +12,7 @@ fun main() = runBlocking {
 
   val wsServer = WebsocketServer()
 
-  val topology = FactorioEventsTopology(wsServer)
+  val topology = KafkatorioTopology(wsServer)
   topology.build()
 
   wsServer.build().asServer(Undertow(9073)).start().block()