diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/colourMapChunks.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/colourMapChunks.kt index 050d3a7..fc4e31f 100644 --- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/colourMapChunks.kt +++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/colourMapChunks.kt @@ -72,22 +72,6 @@ fun colourMapChunks(builder: StreamsBuilder): Topology { .streamTo(to, TOPIC_GROUPED_MAP_CHUNKS_STATE) } -// val chunkTilesColouredTable064 = -// chunkTilesColouredTable032.groupByChunkPosition(ChunkSize.CHUNK_064) -// chunkTilesColouredTable064.streamTo(ChunkSize.CHUNK_064, TOPIC_GROUPED_MAP_CHUNKS_STATE) -// -// val chunkTilesColouredTable128 = -// chunkTilesColouredTable064.groupByChunkPosition(ChunkSize.CHUNK_128) -// chunkTilesColouredTable128.streamTo(ChunkSize.CHUNK_128, TOPIC_GROUPED_MAP_CHUNKS_STATE) -// -// val chunkTilesColouredTable256 = -// chunkTilesColouredTable128.groupByChunkPosition(ChunkSize.CHUNK_256) -// chunkTilesColouredTable256.streamTo(ChunkSize.CHUNK_256, TOPIC_GROUPED_MAP_CHUNKS_STATE) -// -// val chunkTilesColouredTable512 = -// chunkTilesColouredTable256.groupByChunkPosition(ChunkSize.CHUNK_512) -// chunkTilesColouredTable512.streamTo(ChunkSize.CHUNK_512, TOPIC_GROUPED_MAP_CHUNKS_STATE) - return builder.build() }