diff options
Diffstat (limited to 'kafka/util.py')
| -rw-r--r-- | kafka/util.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/kafka/util.py b/kafka/util.py index e4a3db0..96b3745 100644 --- a/kafka/util.py +++ b/kafka/util.py @@ -26,14 +26,14 @@ def read_short_string(data, cur): (strlen,) = struct.unpack('>h', data[cur:cur + 2]) if strlen == -1: - return (None, cur + 2) + return None, cur + 2 cur += 2 if len(data) < cur + strlen: raise BufferUnderflowError("Not enough data left") out = data[cur:cur + strlen] - return (out, cur + strlen) + return out, cur + strlen def read_int_string(data, cur): @@ -43,14 +43,14 @@ def read_int_string(data, cur): (strlen,) = struct.unpack('>i', data[cur:cur + 4]) if strlen == -1: - return (None, cur + 4) + return None, cur + 4 cur += 4 if len(data) < cur + strlen: raise BufferUnderflowError("Not enough data left") out = data[cur:cur + strlen] - return (out, cur + strlen) + return out, cur + strlen def relative_unpack(fmt, data, cur): @@ -59,7 +59,7 @@ def relative_unpack(fmt, data, cur): raise BufferUnderflowError("Not enough data left") out = struct.unpack(fmt, data[cur:cur + size]) - return (out, cur + size) + return out, cur + size def group_by_topic_and_partition(tuples): |