diff --git a/kafka/util.py b/kafka/util.py
index d580ad7..259e285 100644
--- a/kafka/util.py
+++ b/kafka/util.py
@@ -3,6 +3,8 @@ from itertools import groupby
 import struct
 from threading import Thread, Event
 
+from common import *
+
 
 def write_int_string(s):
     if s is None: