KafkaConsumer should be in __all__.

2015-01-09 10:47:35 +01:00
parent 02c2b46900
commit c2a23b9d87
1 changed files with 1 additions and 1 deletions
--- a/kafka/init.py
+++ b/kafka/init.py
@@ -19,5 +19,5 @@ __all__ = [
    'KafkaClient', 'KafkaConnection', 'SimpleProducer', 'KeyedProducer',
    'RoundRobinPartitioner', 'HashedPartitioner', 'SimpleConsumer',
    'MultiProcessConsumer', 'create_message', 'create_gzip_message',
-    'create_snappy_message'
+    'create_snappy_message', 'KafkaConsumer',
 ]