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

use compact size for collections (I think I tried this already and it failed - but I'm going to wipe all data this time, so hopefully it works)

Browse source
This commit is contained in:
Adam 2022-02-20 12:32:17 +01:00
parent 2aed3a670c
commit a8337552e6
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/kxsBinary.kt
View file

@ -65,7 +65,7 @@ class KxsDataOutputEncoder(
descriptor: SerialDescriptor, descriptor: SerialDescriptor,
collectionSize: Int collectionSize: Int
): CompositeEncoder { ): CompositeEncoder {
encodeInt(collectionSize) encodeCompactSize(collectionSize)
return this return this
} }
@ -125,7 +125,7 @@ class KxsDataInputDecoder(
override fun decodeSequentially(): Boolean = true override fun decodeSequentially(): Boolean = true
override fun decodeCollectionSize(descriptor: SerialDescriptor): Int = override fun decodeCollectionSize(descriptor: SerialDescriptor): Int =
decodeInt().also { elementsCount = it } decodeCompactSize().also { elementsCount = it }
override fun decodeNotNullMark(): Boolean = decodeBoolean() override fun decodeNotNullMark(): Boolean = decodeBoolean()