diff options
Diffstat (limited to 'kafka/consumer')
| -rw-r--r-- | kafka/consumer/group.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index b7093f3..0814983 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -154,7 +154,7 @@ class KafkaConsumer(object): self._fetcher = Fetcher( self._client, self._subscription, **self.config) self._coordinator = ConsumerCoordinator( - self._client, self.config['group_id'], self._subscription, + self._client, self._subscription, assignors=self.config['partition_assignment_strategy'], **self.config) self._closed = False |