diff options
Diffstat (limited to 'kafka/protocol')
-rw-r--r-- | kafka/protocol/__init__.py | 2 | ||||
-rw-r--r-- | kafka/protocol/admin.py | 4 | ||||
-rw-r--r-- | kafka/protocol/api.py | 4 | ||||
-rw-r--r-- | kafka/protocol/commit.py | 4 | ||||
-rw-r--r-- | kafka/protocol/fetch.py | 4 | ||||
-rw-r--r-- | kafka/protocol/group.py | 6 | ||||
-rw-r--r-- | kafka/protocol/message.py | 10 | ||||
-rw-r--r-- | kafka/protocol/metadata.py | 4 | ||||
-rw-r--r-- | kafka/protocol/offset.py | 4 | ||||
-rw-r--r-- | kafka/protocol/produce.py | 4 | ||||
-rw-r--r-- | kafka/protocol/struct.py | 6 | ||||
-rw-r--r-- | kafka/protocol/types.py | 2 |
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): |