From 08a815cc0ad5e1eaa4ef865157b248b803d9934f Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 28 Sep 2016 12:41:28 -0700 Subject: Make DefaultPartitioner importable from kafka.partitioner --- kafka/partitioner/__init__.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'kafka') diff --git a/kafka/partitioner/__init__.py b/kafka/partitioner/__init__.py index 9ce6ade..299b485 100644 --- a/kafka/partitioner/__init__.py +++ b/kafka/partitioner/__init__.py @@ -1,9 +1,10 @@ from __future__ import absolute_import -from .roundrobin import RoundRobinPartitioner +from .default import DefaultPartitioner from .hashed import HashedPartitioner, Murmur2Partitioner, LegacyPartitioner +from .roundrobin import RoundRobinPartitioner __all__ = [ - 'RoundRobinPartitioner', 'HashedPartitioner', 'Murmur2Partitioner', - 'LegacyPartitioner' + 'DefaultPartitioner', 'RoundRobinPartitioner', 'HashedPartitioner', + 'Murmur2Partitioner', 'LegacyPartitioner' ] -- cgit v1.2.1