summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2017-12-12 09:21:50 -0800
committerDana Powers <dana.powers@gmail.com>2017-12-12 09:21:50 -0800
commit68a416ad151839ff7a070ba809d0ca3d734ace26 (patch)
treec87739d8745d9d860caaf8b51514e5c85acd305e
parent04fb37f690df5d887f9f191dc4d07408307c8207 (diff)
downloadkafka-python-68a416ad151839ff7a070ba809d0ca3d734ace26.tar.gz
Raise better struct pack/unpack errors (#1320)
-rw-r--r--kafka/protocol/types.py12
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):