diff options
Diffstat (limited to 'kafka/client.py')
-rw-r--r-- | kafka/client.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/client.py b/kafka/client.py index 1016051..550da08 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -158,6 +158,9 @@ class KafkaClient(object): # Order the accumulated responses by the original key order return (acc[k] for k in original_keys) if acc else () + def __repr__(self): + return '<KafkaClient client_id=%s>' % (self.client_id) + def _raise_on_response_error(self, resp): if resp.error == ErrorMapping.NO_ERROR: return |