Flush writer on close

sksamuel · Apr 28, 2024 · 06aeb11 · 06aeb11
1 parent 537affe
commit 06aeb11
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/centurion-avro/src/main/kotlin/com/sksamuel/centurion/avro/io/BinaryWriter.kt b/centurion-avro/src/main/kotlin/com/sksamuel/centurion/avro/io/BinaryWriter.kt
@@ -62,6 +62,7 @@ class BinaryWriterFactory(
    fun write(record: GenericRecord, codec: Codec? = null): ByteArray {
       val writer = BinaryWriter(datumWriter, ByteArrayOutputStream(), factory)
       writer.write(record)
+      writer.close()
       return if (codec == null) writer.bytes() else {
          val compressed = codec.compress(ByteBuffer.wrap(writer.bytes()))
          val b = ByteArray(compressed.remaining())