diff options
Diffstat (limited to 'kafka/consumer.py')
| -rw-r--r-- | kafka/consumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index d811147..1c122ce 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -591,7 +591,7 @@ class MultiProcessConsumer(Consumer): for chunk in chunks: chunk = filter(lambda x: x is not None, chunk) args = (client.copy(), - group, topic, chunk, + group, topic, list(chunk), self.queue, self.start, self.exit, self.pause, self.size) |