From f161cd11aa63715979c544ddcaeeb0fabe57b3dd Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 30 Dec 2015 12:21:00 -0800 Subject: Make group_id a Coordinator kwarg (not arg) for consistency --- kafka/consumer/group.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/consumer/group.py') 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 -- cgit v1.2.1