diff options
Diffstat (limited to 'kafka/util.py')
| -rw-r--r-- | kafka/util.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/util.py b/kafka/util.py index 96b3745..54052fb 100644 --- a/kafka/util.py +++ b/kafka/util.py @@ -1,9 +1,8 @@ from collections import defaultdict -from itertools import groupby import struct from threading import Thread, Event -from common import * +from kafka.common import BufferUnderflowError def write_int_string(s): @@ -39,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 to read string len (%d < %d)" % (len(data), cur + 4)) + "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: |