diff options
| -rw-r--r-- | kafka/__init__.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kafka/__init__.py b/kafka/__init__.py index d229169..13af699 100644 --- a/kafka/__init__.py +++ b/kafka/__init__.py @@ -10,9 +10,10 @@ from kafka.protocol import ( create_message, create_gzip_message, create_snappy_message ) from kafka.producer import SimpleProducer -from kafka.consumer import SimpleConsumer +from kafka.consumer import SimpleConsumer, MultiProcessConsumer __all__ = [ - 'KafkaClient', 'KafkaConnection', 'SimpleProducer', 'SimpleConsumer', + 'KafkaClient', 'KafkaConnection', 'SimpleProducer', + 'SimpleConsumer', 'MultiProcessConsumer', 'create_message', 'create_gzip_message', 'create_snappy_message' ] |