diff --git a/modules/events-server/src/test/kotlin/dev/adamko/kafkatorio/processor/topology/SaveMapChunksTest.kt b/modules/events-server/src/test/kotlin/dev/adamko/kafkatorio/processor/topology/SaveMapChunksTest.kt
index 22dd44b..bc427b8 100644
--- a/modules/events-server/src/test/kotlin/dev/adamko/kafkatorio/processor/topology/SaveMapChunksTest.kt
+++ b/modules/events-server/src/test/kotlin/dev/adamko/kafkatorio/processor/topology/SaveMapChunksTest.kt
@@ -69,7 +69,7 @@ class SaveMapChunksTest : FunSpec({
   class Scenario(
     streamsBuilder: StreamsBuilder = StreamsBuilder(),
 
-    groupedMapChunksInputTopicName: String = "kafkatorio.state.map-chunks.grouped.debounced",
+    groupedMapChunksInputTopicName: String = "kafkatorio.state.map-chunk.colour",
 
     val serverId: FactorioServerId = FactorioServerId("test-server-id"),
   ) : AutoCloseable {
@@ -169,7 +169,7 @@ class SaveMapChunksTest : FunSpec({
       return arbitrary {
         val chunkId = serverMapChunkId.bind()
 
-        val tileColoursArb = tilesInChunkArb(serverMapChunkId.bind())
+        val tileColoursArb = tilesInChunkArb(chunkId)
 
         ServerMapChunkTiles(
           chunkId = chunkId,