summaryrefslogtreecommitdiff
path: root/kafka/__init__.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-12-17 17:06:46 -0800
committerDana Powers <dana.powers@gmail.com>2016-12-17 17:06:46 -0800
commit64347bd9faa0a314c3c49b48df941d3022f9e311 (patch)
treef6957cb1f95a7f2a951123975b205323d6d70618 /kafka/__init__.py
parent07e09c1c2ec6787fc7e4f3c2578d31b4a15d20bc (diff)
downloadkafka-python-serialize_interface.tar.gz
Add kafka.serializer interfacesserialize_interface
Diffstat (limited to 'kafka/__init__.py')
-rw-r--r--kafka/__init__.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/__init__.py b/kafka/__init__.py
index 0d7d113..6a80418 100644
--- a/kafka/__init__.py
+++ b/kafka/__init__.py
@@ -26,6 +26,7 @@ from kafka.protocol import (
create_message, create_gzip_message, create_snappy_message)
from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner, Murmur2Partitioner
from kafka.structs import TopicPartition, OffsetAndMetadata
+from kafka.serializer import Serializer, Deserializer
# To be deprecated when KafkaProducer interface is released
from kafka.client import SimpleClient