diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-24 18:03:56 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-24 18:03:56 +0530 |
| commit | eee55aec2638050e8f9a1c9953515b172d06ea51 (patch) | |
| tree | 361733b0edba75ceb9267a50dfa505b29d26d3e6 /kafka/__init__.py | |
| parent | e690b75590837f24d456bb5e5c766dac8ac093ad (diff) | |
| download | kafka-python-eee55aec2638050e8f9a1c9953515b172d06ea51.tar.gz | |
Add exports in __init__
Diffstat (limited to 'kafka/__init__.py')
| -rw-r--r-- | kafka/__init__.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/kafka/__init__.py b/kafka/__init__.py index d229169..e352c03 100644 --- a/kafka/__init__.py +++ b/kafka/__init__.py @@ -9,10 +9,12 @@ from kafka.conn import KafkaConnection from kafka.protocol import ( create_message, create_gzip_message, create_snappy_message ) -from kafka.producer import SimpleProducer +from kafka.producer import SimpleProducer, KeyedProducer +from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner from kafka.consumer import SimpleConsumer __all__ = [ - 'KafkaClient', 'KafkaConnection', 'SimpleProducer', 'SimpleConsumer', + 'KafkaClient', 'KafkaConnection', 'SimpleProducer', 'KeyedProducer', + 'RoundRobinPartitioner', 'HashedPartitioner', 'SimpleConsumer', 'create_message', 'create_gzip_message', 'create_snappy_message' ] |