diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-03-03 15:32:32 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-03-03 15:32:32 +0300 |
| commit | ac66fe9159723c6707258bbb4c6727cf66a78219 (patch) | |
| tree | a230134f4e75c574564104a9bc11dfb24fb2293e | |
| parent | 9ad0be662d388b47aadf04d712f5744add6456e3 (diff) | |
| download | kafka-python-ac66fe9159723c6707258bbb4c6727cf66a78219.tar.gz | |
Fixing distribution for MP Consumer
| -rw-r--r-- | kafka/consumer/multiprocess.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/multiprocess.py b/kafka/consumer/multiprocess.py index 4dc04dc..40aecf8 100644 --- a/kafka/consumer/multiprocess.py +++ b/kafka/consumer/multiprocess.py @@ -131,7 +131,7 @@ class MultiProcessConsumer(Consumer): # * we have an even distribution of partitions among processes if not partitions_per_proc: partitions_per_proc = round(len(partitions) * 1.0 / num_procs) - if partitions_per_proc < num_procs * 0.5: + if partitions_per_proc * num_procs < len(partitions): partitions_per_proc += 1 # The final set of chunks |