summaryrefslogtreecommitdiff
path: root/kafka/protocol/__init__.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/protocol/__init__.py')
-rw-r--r--kafka/protocol/__init__.py2
1 files changed, 1 insertions, 1 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,