use absolute imports everywhere (#1362)

12 files changed, 27 insertions, 27 deletions

diff --git a/kafka/protocol/__init__.py b/kafka/protocol/__init__.py
index 4dcf4a4..55ecb86 100644
--- a/kafka/protocol/__init__.py
+++ b/kafka/protocol/__init__.py
@@ -1,6 +1,6 @@
 from __future__ import absolute_import
 
-from .legacy import (
+from kafka.protocol.legacy import (
     create_message, create_gzip_message,
     create_snappy_message, create_message_set,
     CODEC_NONE, CODEC_GZIP, CODEC_SNAPPY, ALL_CODECS,
diff --git a/kafka/protocol/admin.py b/kafka/protocol/admin.py
index b787c5f..9d4f17f 100644
--- a/kafka/protocol/admin.py
+++ b/kafka/protocol/admin.py
@@ -1,7 +1,7 @@
 from __future__ import absolute_import
 
-from .api import Request, Response
-from .types import Array, Boolean, Bytes, Int16, Int32, Schema, String
+from kafka.protocol.api import Request, Response
+from kafka.protocol.types import Array, Boolean, Bytes, Int16, Int32, Schema, String
 
 
 class ApiVersionResponse_v0(Response):
diff --git a/kafka/protocol/api.py b/kafka/protocol/api.py
index ec24a39..efaf63e 100644
--- a/kafka/protocol/api.py
+++ b/kafka/protocol/api.py
@@ -2,8 +2,8 @@ from __future__ import absolute_import
 
 import abc
 
-from .struct import Struct
-from .types import Int16, Int32, String, Schema
+from kafka.protocol.struct import Struct
+from kafka.protocol.types import Int16, Int32, String, Schema
 
 
 class RequestHeader(Struct):
diff --git a/kafka/protocol/commit.py b/kafka/protocol/commit.py
index 9d744c7..31fc237 100644
--- a/kafka/protocol/commit.py
+++ b/kafka/protocol/commit.py
@@ -1,7 +1,7 @@
 from __future__ import absolute_import
 
-from .api import Request, Response
-from .types import Array, Int8, Int16, Int32, Int64, Schema, String
+from kafka.protocol.api import Request, Response
+from kafka.protocol.types import Array, Int8, Int16, Int32, Int64, Schema, String
 
 
 class OffsetCommitResponse_v0(Response):
diff --git a/kafka/protocol/fetch.py b/kafka/protocol/fetch.py
index 5fc17e0..dd3f648 100644
--- a/kafka/protocol/fetch.py
+++ b/kafka/protocol/fetch.py
@@ -1,7 +1,7 @@
 from __future__ import absolute_import
 
-from .api import Request, Response
-from .types import Array, Int8, Int16, Int32, Int64, Schema, String, Bytes
+from kafka.protocol.api import Request, Response
+from kafka.protocol.types import Array, Int8, Int16, Int32, Int64, Schema, String, Bytes
 
 
 class FetchResponse_v0(Response):
diff --git a/kafka/protocol/group.py b/kafka/protocol/group.py
index db84427..bcb9655 100644
--- a/kafka/protocol/group.py
+++ b/kafka/protocol/group.py
@@ -1,8 +1,8 @@
 from __future__ import absolute_import
 
-from .api import Request, Response
-from .struct import Struct
-from .types import Array, Bytes, Int16, Int32, Schema, String
+from kafka.protocol.api import Request, Response
+from kafka.protocol.struct import Struct
+from kafka.protocol.types import Array, Bytes, Int16, Int32, Schema, String
 
 
 class JoinGroupResponse_v0(Response):
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py
index a330ed8..19dcbd9 100644
--- a/kafka/protocol/message.py
+++ b/kafka/protocol/message.py
@@ -3,15 +3,15 @@ from __future__ import absolute_import
 import io
 import time
 
-from ..codec import (has_gzip, has_snappy, has_lz4,
+from kafka.codec import (has_gzip, has_snappy, has_lz4,
                      gzip_decode, snappy_decode,
                      lz4_decode, lz4_decode_old_kafka)
-from .frame import KafkaBytes
-from .struct import Struct
-from .types import (
+from kafka.protocol.frame import KafkaBytes
+from kafka.protocol.struct import Struct
+from kafka.protocol.types import (
     Int8, Int32, Int64, Bytes, Schema, AbstractType
 )
-from ..util import crc32, WeakMethod
+from kafka.util import crc32, WeakMethod
 
 
 class Message(Struct):
diff --git a/kafka/protocol/metadata.py b/kafka/protocol/metadata.py
index 2aafdd3..414e5b8 100644
--- a/kafka/protocol/metadata.py
+++ b/kafka/protocol/metadata.py
@@ -1,7 +1,7 @@
 from __future__ import absolute_import
 
-from .api import Request, Response
-from .types import Array, Boolean, Int16, Int32, Schema, String
+from kafka.protocol.api import Request, Response
+from kafka.protocol.types import Array, Boolean, Int16, Int32, Schema, String
 
 
 class MetadataResponse_v0(Response):
diff --git a/kafka/protocol/offset.py b/kafka/protocol/offset.py
index 5179658..3c254de 100644
--- a/kafka/protocol/offset.py
+++ b/kafka/protocol/offset.py
@@ -1,7 +1,7 @@
 from __future__ import absolute_import
 
-from .api import Request, Response
-from .types import Array, Int8, Int16, Int32, Int64, Schema, String
+from kafka.protocol.api import Request, Response
+from kafka.protocol.types import Array, Int8, Int16, Int32, Int64, Schema, String
 
 UNKNOWN_OFFSET = -1
 
diff --git a/kafka/protocol/produce.py b/kafka/protocol/produce.py
index 5fbddec..f4032b3 100644
--- a/kafka/protocol/produce.py
+++ b/kafka/protocol/produce.py
@@ -1,7 +1,7 @@
 from __future__ import absolute_import
 
-from .api import Request, Response
-from .types import Int16, Int32, Int64, String, Array, Schema, Bytes
+from kafka.protocol.api import Request, Response
+from kafka.protocol.types import Int16, Int32, Int64, String, Array, Schema, Bytes
 
 
 class ProduceResponse_v0(Response):
diff --git a/kafka/protocol/struct.py b/kafka/protocol/struct.py
index 3288172..676de1b 100644
--- a/kafka/protocol/struct.py
+++ b/kafka/protocol/struct.py
@@ -2,10 +2,10 @@ from __future__ import absolute_import
 
 from io import BytesIO
 
-from .abstract import AbstractType
-from .types import Schema
+from kafka.protocol.abstract import AbstractType
+from kafka.protocol.types import Schema
 
-from ..util import WeakMethod
+from kafka.util import WeakMethod
 
 
 class Struct(AbstractType):
diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py
index 6a6e89e..d5e446a 100644
--- a/kafka/protocol/types.py
+++ b/kafka/protocol/types.py
@@ -2,7 +2,7 @@ from __future__ import absolute_import
 
 from struct import pack, unpack, error
 
-from .abstract import AbstractType
+from kafka.protocol.abstract import AbstractType
 
 
 def _pack(f, value):