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/consumer.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/consumer.py')
-rw-r--r-- | kafka/consumer.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index 522d6ca..5be1bef 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -256,6 +256,10 @@ class SimpleConsumer(Consumer): auto_commit_every_n=auto_commit_every_n, auto_commit_every_t=auto_commit_every_t) + def __repr__(self): + return '<SimpleConsumer group=%s, topic=%s, partitions=%s>' % \ + (self.group, self.topic, str(self.offsets.keys())) + def provide_partition_info(self): """ Indicates that partition info must be returned by the consumer @@ -544,6 +548,10 @@ class MultiProcessConsumer(Consumer): proc.start() self.procs.append(proc) + def __repr__(self): + return '<MultiProcessConsumer group=%s, topic=%s, consumers=%d>' % \ + (self.group, self.topic, len(self.procs)) + def stop(self): # Set exit and start off all waiting consumers self.exit.set() |