From a8337552e61fc737e743135eeb227d8fe7fdd62d Mon Sep 17 00:00:00 2001
From: Adam <897017+aSemy@users.noreply.github.com>
Date: Sun, 20 Feb 2022 12:32:17 +0100
Subject: [PATCH] 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)

---
 .../dev/adamko/kafkatorio/processor/serdes/kxsBinary.kt       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/kxsBinary.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/kxsBinary.kt
index de83b36..f61bf25 100644
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/kxsBinary.kt
+++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/kxsBinary.kt
@@ -65,7 +65,7 @@ class KxsDataOutputEncoder(
     descriptor: SerialDescriptor,
     collectionSize: Int
   ): CompositeEncoder {
-    encodeInt(collectionSize)
+    encodeCompactSize(collectionSize)
     return this
   }
 
@@ -125,7 +125,7 @@ class KxsDataInputDecoder(
   override fun decodeSequentially(): Boolean = true
 
   override fun decodeCollectionSize(descriptor: SerialDescriptor): Int =
-    decodeInt().also { elementsCount = it }
+    decodeCompactSize().also { elementsCount = it }
 
   override fun decodeNotNullMark(): Boolean = decodeBoolean()