From f9f9976b8a99b7447a4ef2a3da37321f469866cb Mon Sep 17 00:00:00 2001
From: Oleksandr Sulyma <sulyma.alex@gmail.com>
Date: Wed, 24 Jun 2026 14:39:02 +0300
Subject: [PATCH] Fix IndexError in UnsignedVarInt32.encode_into for large
 records

---
 kafka/protocol/schemas/fields/codecs/types.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/kafka/protocol/schemas/fields/codecs/types.py b/kafka/protocol/schemas/fields/codecs/types.py
index e423cd02a..239e8fb15 100644
--- a/kafka/protocol/schemas/fields/codecs/types.py
+++ b/kafka/protocol/schemas/fields/codecs/types.py
@@ -341,6 +341,7 @@ def encode(cls, value, compact=False):
 
     @classmethod
     def encode_into(cls, out, value):
+        out.ensure(5)
         buf = out.buf
         pos = out.pos
         while (value & 0xffffff80) != 0: