diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-25 11:54:07 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-25 11:54:07 +0530 |
| commit | 2e38a5273270df8959279973cbac69e5658ec9a9 (patch) | |
| tree | 3c861ac83f10e409a009be3d168d30168eeec0f0 /kafka | |
| parent | c7dfebaa8d9ee6bc6af8f1d03557ed1e089a0f65 (diff) | |
| download | kafka-python-2e38a5273270df8959279973cbac69e5658ec9a9.tar.gz | |
Added the modules in __init__.py
Diffstat (limited to 'kafka')
| -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' ] |