From deb584c90802d382ca376331a8bf31bfb12d94dc Mon Sep 17 00:00:00 2001 From: mrtheb Date: Tue, 1 Oct 2013 15:15:36 -0400 Subject: Cherry-pick mrtheb/kafka-python 2b016b69 Set FetchRequest MaxBytes value to bufsize instead of fetchsize (=MinBytes) --- kafka/util.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'kafka/util.py') 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 -- cgit v1.2.1