From 06aeb11ec46b456c513898ff7e7c03cff30d4db0 Mon Sep 17 00:00:00 2001
From: sksamuel <sam@sksamuel.com>
Date: Sat, 27 Apr 2024 22:19:00 -0500
Subject: [PATCH] Flush writer on close

---
 .../main/kotlin/com/sksamuel/centurion/avro/io/BinaryWriter.kt   | 1 +
 1 file changed, 1 insertion(+)

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
index 97763ab..0daaa74 100644
--- 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())