diff --git a/src/MySQLReplication/JsonBinaryDecoder/JsonBinaryDecoderService.php b/src/MySQLReplication/JsonBinaryDecoder/JsonBinaryDecoderService.php
index 9e72019..dc54782 100644
--- a/src/MySQLReplication/JsonBinaryDecoder/JsonBinaryDecoderService.php
+++ b/src/MySQLReplication/JsonBinaryDecoder/JsonBinaryDecoderService.php
@@ -85,6 +85,7 @@ public function parseToString(): string
      */
     private function parseJson(int $type): void
     {
+        $results = [];
         if (self::SMALL_OBJECT === $type) {
             $results[self::OBJECT] = $this->parseArrayOrObject(self::OBJECT, self::SMALL_OFFSET_SIZE);
         } else if (self::LARGE_OBJECT === $type) {
diff --git a/src/MySQLReplication/JsonBinaryDecoder/JsonBinaryDecoderValue.php b/src/MySQLReplication/JsonBinaryDecoder/JsonBinaryDecoderValue.php
index bf12ace..34c4fff 100644
--- a/src/MySQLReplication/JsonBinaryDecoder/JsonBinaryDecoderValue.php
+++ b/src/MySQLReplication/JsonBinaryDecoder/JsonBinaryDecoderValue.php
@@ -22,7 +22,7 @@ public function __construct(
         $this->offset = $offset;
     }
 
-    public function getOffset(): int
+    public function getOffset(): ?int
     {
         return $this->offset;
     }