diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-30 12:21:00 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-30 12:21:00 -0800 |
| commit | f161cd11aa63715979c544ddcaeeb0fabe57b3dd (patch) | |
| tree | 733a6a0571f54250c4a5024fa757444f930bcf5b /kafka/consumer/group.py | |
| parent | 61161d8335bba3f1786f10a321a2a9e915adb286 (diff) | |
| download | kafka-python-f161cd11aa63715979c544ddcaeeb0fabe57b3dd.tar.gz | |
Make group_id a Coordinator kwarg (not arg) for consistency
Diffstat (limited to 'kafka/consumer/group.py')
| -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 |