Not an instance attribute.

Author: Julian

kafka/producer/kafka.py

@@ -274,7 +274,7 @@ def __init__(self, **configs):
         if self.config['acks'] == 'all':
             self.config['acks'] = -1
 
-        self.client = self.config['client'] or KafkaClient(**self.config)
+        client = self.config['client'] or KafkaClient(**self.config)
 
         # Check Broker Version if not set explicitly
         if self.config['api_version'] == 'auto':