diff options
Diffstat (limited to 'kafka/util.py')
| -rw-r--r-- | kafka/util.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/kafka/util.py b/kafka/util.py index 259e285..598ba84 100644 --- a/kafka/util.py +++ b/kafka/util.py @@ -38,7 +38,8 @@ def read_short_string(data, cur): def read_int_string(data, cur): if len(data) < cur + 4: - raise BufferUnderflowError("Not enough data left") + raise BufferUnderflowError( + "Not enough data left to read string len (%d < %d)" % (len(data), cur + 4)) (strLen,) = struct.unpack('>i', data[cur:cur + 4]) if strLen == -1: @@ -46,7 +47,8 @@ def read_int_string(data, cur): cur += 4 if len(data) < cur + strLen: - raise BufferUnderflowError("Not enough data left") + raise BufferUnderflowError( + "Not enough data left to read string (%d < %d)" % (len(data), cur + strLen)) out = data[cur:cur + strLen] return (out, cur + strLen) @@ -68,7 +70,6 @@ def group_by_topic_and_partition(tuples): return out - class ReentrantTimer(object): """ A timer that can be restarted, unlike threading.Timer |