diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/groupMapChunks.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/groupMapChunks.kt
index 3122622..9ac4fff 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/groupMapChunks.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/groupMapChunks.kt
@@ -56,31 +56,9 @@ fun groupMapChunks(builder: StreamsBuilder): Topology {
   val mapChunksStream: KStream<FactorioServerId, MapChunkUpdate> = builder.streamPacketData()
   val protosStream: KStream<FactorioServerId, PrototypesUpdate> = builder.streamPacketData()
 
-//  val protosStream: KStream<FactorioServerId, KafkatorioPacket2> =
-//    builder.stream<FactorioServerId?, KafkatorioPacket2?>(
-//      prototypesTopicName,
-//      consumedAs("consume.factorio-protos.all", jsonMapper.serde(), jsonMapper.serde())
-//    ).filter { key: FactorioServerId?, value: KafkatorioPacket2? ->
-//      key != null
-//          && value != null
-//          && value.data ==
-//    }
-//      .map
-
-
   val tileProtoColourDict: KTable<FactorioServerId, TileColourDict> =
     tileProtoColourDictionary(protosStream)
 
-//  val mapChunksUpdatesStream: KStream<FactorioServerId, FactorioEventUpdatePacket> =
-//    builder.stream(
-//      mapChunkUpdatesTopicName,
-//      consumedAs(
-//        "consume.map-chunk-updates",
-//        jsonMapper.serde<FactorioServerId>(),
-//        jsonMapper.serde<FactorioEventUpdatePacket>(),
-//      )
-//    )
-
   val groupedMapChunkTiles: KTable<ServerMapChunkId, ServerMapChunkTiles<ColourHex>> =
     groupTilesIntoChunksWithColours(
       mapChunksStream,
diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/model.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/model.kt
index 3ed4ef8..376e63d 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/model.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/model.kt
@@ -7,7 +7,7 @@ import kotlinx.serialization.Serializable
 
 @JvmInline
 @Serializable
-value class FactorioServerId(val id: String) {
+value class FactorioServerId(private val id: String) {
   override fun toString() = id
 }