openstack/deb-python-kafka
Code Issues Proposed changes

Added the modules in __init__.py

Browse Source
This commit is contained in:
Mahendra M
2013-06-25 11:54:07 +05:30
parent c7dfebaa8d
commit 2e38a52732
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
kafka/__init__.py
View File

@@ -10,9 +10,10 @@ from kafka.protocol import (
create_message, create_gzip_message, create_snappy_message create_message, create_gzip_message, create_snappy_message
) )
from kafka.producer import SimpleProducer from kafka.producer import SimpleProducer
from kafka.consumer import SimpleConsumer from kafka.consumer import SimpleConsumer, MultiProcessConsumer
__all__ = [ __all__ = [
'KafkaClient', 'KafkaConnection', 'SimpleProducer', 'SimpleConsumer', 'KafkaClient', 'KafkaConnection', 'SimpleProducer',
'SimpleConsumer', 'MultiProcessConsumer',
'create_message', 'create_gzip_message', 'create_snappy_message' 'create_message', 'create_gzip_message', 'create_snappy_message'
] ]