summaryrefslogtreecommitdiff
path: root/kafka/__init__.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/__init__.py')
-rw-r--r--kafka/__init__.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/__init__.py b/kafka/__init__.py
index 58ca619..16b9094 100644
--- a/kafka/__init__.py
+++ b/kafka/__init__.py
@@ -13,7 +13,7 @@ from kafka.protocol import (
)
from kafka.producer import SimpleProducer, KeyedProducer
from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner
-from kafka.consumer import SimpleConsumer, MultiProcessConsumer
+from kafka.consumer import SimpleConsumer, MultiProcessConsumer, KafkaConsumer
__all__ = [
'KafkaClient', 'KafkaConnection', 'SimpleProducer', 'KeyedProducer',