12 files changed, 24 insertions, 0 deletions
diff --git a/kafka/protocol/__init__.py b/kafka/protocol/__init__.py
index 7b2a2f3..2a269a5 100644
--- a/kafka/protocol/__init__.py
+++ b/kafka/protocol/__init__.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .legacy import (
     create_message, create_gzip_message,
     create_snappy_message, create_message_set,
diff --git a/kafka/protocol/abstract.py b/kafka/protocol/abstract.py
index 160678f..2de65c4 100644
--- a/kafka/protocol/abstract.py
+++ b/kafka/protocol/abstract.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import abc
 
 
diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py
index 706bc3a..12181d7 100644
--- a/kafka/protocol/admin.py
+++ b/kafka/protocol/admin.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Bytes, Int16, Schema, String
 
diff --git a/kafka/protocol/api.py b/kafka/protocol/api.py
index 0c23437..7779aac 100644
--- a/kafka/protocol/api.py
+++ b/kafka/protocol/api.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Int16, Int32, String, Schema
 
diff --git a/kafka/protocol/commit.py b/kafka/protocol/commit.py
index 90a3b76..69201be 100644
--- a/kafka/protocol/commit.py
+++ b/kafka/protocol/commit.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Int16, Int32, Int64, Schema, String
 
diff --git a/kafka/protocol/fetch.py b/kafka/protocol/fetch.py
index 0542ad2..7df6627 100644
--- a/kafka/protocol/fetch.py
+++ b/kafka/protocol/fetch.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .message import MessageSet
 from .struct import Struct
 from .types import Array, Int16, Int32, Int64, Schema, String
diff --git a/kafka/protocol/group.py b/kafka/protocol/group.py
index c49cfc8..98715f3 100644
--- a/kafka/protocol/group.py
+++ b/kafka/protocol/group.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Bytes, Int16, Int32, Schema, String
 
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py
index 795495d..f333800 100644
--- a/kafka/protocol/message.py
+++ b/kafka/protocol/message.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 import io
 import time
 
diff --git a/kafka/protocol/metadata.py b/kafka/protocol/metadata.py
index 2711abb..7a04104 100644
--- a/kafka/protocol/metadata.py
+++ b/kafka/protocol/metadata.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Boolean, Int16, Int32, Schema, String
 
diff --git a/kafka/protocol/offset.py b/kafka/protocol/offset.py
index 57bf4ac..8d66063 100644
--- a/kafka/protocol/offset.py
+++ b/kafka/protocol/offset.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .struct import Struct
 from .types import Array, Int16, Int32, Int64, Schema, String
 
diff --git a/kafka/protocol/produce.py b/kafka/protocol/produce.py
index 560f92f..c1a519e 100644
--- a/kafka/protocol/produce.py
+++ b/kafka/protocol/produce.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from .message import MessageSet
 from .struct import Struct
 from .types import Int16, Int32, Int64, String, Array, Schema
diff --git a/kafka/protocol/struct.py b/kafka/protocol/struct.py
index ca1013e..602cfb8 100644
--- a/kafka/protocol/struct.py
+++ b/kafka/protocol/struct.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 #from collections import namedtuple
 from io import BytesIO