From 31f10ce9f824dc1258831654b5f104de2911f30b Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 21 Mar 2026 20:32:28 -0700 Subject: [PATCH] Validate DataContainer version --- kafka/protocol/new/data_container.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/kafka/protocol/new/data_container.py b/kafka/protocol/new/data_container.py index 56ca3e296..098d8ff94 100644 --- a/kafka/protocol/new/data_container.py +++ b/kafka/protocol/new/data_container.py @@ -24,6 +24,8 @@ def __init_subclass__(cls, **kwargs): def __init__(self, *args, version=None, **field_vals): assert self._struct is not None + if version is not None and not self._struct.min_version <= version <= self._struct.max_version: + raise ValueError(f'Invalid version: {version} (min={self._struct.min_version}, max={self._struct.max_version})') self._version = version # Support positional arg init for convenience if len(args) > 0: