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

version bumps, schema tweaks, code tweaks,

Browse source
This commit is contained in:
Adam 2022-03-04 23:54:45 +01:00
parent b055397d25
commit a9782a4d90
15 changed files with 954 additions and 59 deletions
Download patch file Download diff file Expand all files Collapse all files

3
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/KafkatorioTopology.kt
View file

@ -109,7 +109,6 @@ internal class KafkatorioTopology(
)
)
val topology = builder.build()
launchTopology("groupTilesMapChunks", topology)
}
@ -117,7 +116,7 @@ internal class KafkatorioTopology(
private fun saveTiles() {
val builder = StreamsBuilder()
val groupedMapChunkTiles: KTable<ServerMapChunkId, ServerMapChunkTiles<ColourHex>> =
val groupedMapChunkTiles: KTable<ServerMapChunkId?, ServerMapChunkTiles<ColourHex>?> =
builder.table(
TOPIC_GROUPED_MAP_CHUNKS,
consumedAs("consume.grouped-map-chunks", kxsBinary.serde(), kxsBinary.serde())

2
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/topology/flowMapTiles.kt
View file

@ -47,7 +47,7 @@ private val serverMapChunkHandler = ServerMapChunkHandler()
fun saveMapTiles(
serverMapTable: KTable<ServerMapChunkId, ServerMapChunkTiles<ColourHex>>
serverMapTable: KTable<ServerMapChunkId?, ServerMapChunkTiles<ColourHex>?>
) {
serverMapTable