Validate DataContainer version

Author: dpkp

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: