Sort partitions before calling partitioner (#905)

1 files changed, 7 insertions, 0 deletions

diff --git a/kafka/partitioner/default.py b/kafka/partitioner/default.py
index 79205b6..087166c 100644
--- a/kafka/partitioner/default.py
+++ b/kafka/partitioner/default.py
@@ -14,6 +14,13 @@ class DefaultPartitioner(object):
     """
     @classmethod
     def __call__(cls, key, all_partitions, available):
+        """
+        Get the partition corresponding to key
+        :param key: partitioning key
+        :param all_partitions: list of all partitions sorted by partition ID
+        :param available: list of available partitions in no particular order
+        :return: one of the values from all_partitions or available
+        """
         if key is None:
             if available:
                 return random.choice(available)