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: