diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-24 18:14:04 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-24 18:14:04 +0530 |
| commit | e85190e6f6d8ea554df96b2b445924591bd561b6 (patch) | |
| tree | 9aefa1f6b96d21e83147632297f803bb1d655b62 /kafka/consumer.py | |
| parent | b578725fc338dc80cb82ad3471d488881f9dd785 (diff) | |
| download | kafka-python-e85190e6f6d8ea554df96b2b445924591bd561b6.tar.gz | |
Minor bug fix
Diffstat (limited to 'kafka/consumer.py')
| -rw-r--r-- | kafka/consumer.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index e6d95d0..7f67cf2 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -384,9 +384,10 @@ class MultiProcessConsumer(Consumer): # Initiate the base consumer class super(MultiProcessConsumer, self).__init__(client, group, topic, - auto_commit, partitions, + auto_commit, auto_commit_every_n, - auto_commit_every_t) + auto_commit_every_t, + partitions=None) # Variables for managing and controlling the data flow from # consumer child process to master |