diff options
| author | mrtheb <mrlabbe@gmail.com> | 2014-01-14 22:57:05 -0500 |
|---|---|---|
| committer | mrtheb <mrlabbe@gmail.com> | 2014-01-14 22:57:05 -0500 |
| commit | fb4903e518d2fde3c01f629f6f24f0598399932c (patch) | |
| tree | 8356bc8847a69db425a5d942fa95354348b3c117 /kafka/client.py | |
| parent | 9644166048d6fe1cdbd1fc3096329ee2142b147e (diff) | |
| parent | ceee715fc7bf17b28ff5a10f1f7decc8974f6506 (diff) | |
| download | kafka-python-fb4903e518d2fde3c01f629f6f24f0598399932c.tar.gz | |
Merge branch 'repr' of https://github.com/mahendra/kafka-python into mahendra-repr
Conflicts:
kafka/client.py
kafka/consumer.py
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 |