Fetcher below would get client twice.

Author: Julian

kafka/consumer/group.py

@@ -230,7 +230,8 @@ def __init__(self, *topics, **configs):
         metric_group_prefix = 'consumer'
         # TODO _metrics likely needs to be passed to KafkaClient, etc.
 
-        self._client = self.config['client'] or KafkaClient(**self.config)
+        client = self.config.pop('client', None) or KafkaClient(**self.config)
+        self._client = client
 
         # Check Broker Version if not set explicitly
         if self.config['api_version'] == 'auto':