openstack/deb-python-kafka
Code Issues Proposed changes

Add Murmur2Partitioner to kafka __all__ imports - fix issue 471

Browse Source
This commit is contained in:
Dana Powers
2015-12-02 14:38:02 -08:00
parent 58e2ab41a7
commit cfbdc05f27
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/__init__.py
View File

@@ -10,7 +10,7 @@ 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, KeyedProducer from kafka.producer import SimpleProducer, KeyedProducer
from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner, Murmur2Partitioner
from kafka.consumer import SimpleConsumer, MultiProcessConsumer, KafkaConsumer from kafka.consumer import SimpleConsumer, MultiProcessConsumer, KafkaConsumer
__all__ = [ __all__ = [