diff options
author | Jeff Widman <jeff@jeffwidman.com> | 2017-12-12 09:21:50 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2017-12-12 09:21:50 -0800 |
commit | 68a416ad151839ff7a070ba809d0ca3d734ace26 (patch) | |
tree | c87739d8745d9d860caaf8b51514e5c85acd305e | |
parent | 04fb37f690df5d887f9f191dc4d07408307c8207 (diff) | |
download | kafka-python-68a416ad151839ff7a070ba809d0ca3d734ace26.tar.gz |
Raise better struct pack/unpack errors (#1320)
-rw-r--r-- | kafka/protocol/types.py | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py index 22b49a4..516b957 100644 --- a/kafka/protocol/types.py +++ b/kafka/protocol/types.py @@ -8,16 +8,20 @@ from .abstract import AbstractType def _pack(f, value): try: return pack(f, value) - except error: - raise ValueError(error) + except error as e: + raise ValueError("Error encountered when attempting to convert value: " + "{} to struct format: '{}', hit error: {}" + .format(value, f, e)) def _unpack(f, data): try: (value,) = unpack(f, data) return value - except error: - raise ValueError(error) + except error as e: + raise ValueError("Error encountered when attempting to convert value: " + "{} to struct format: '{}', hit error: {}" + .format(value, f, e)) class Int8(AbstractType): |