summaryrefslogtreecommitdiff
path: root/kafka/consumer.py
diff options
context:
space:
mode:
authormrtheb <mrlabbe@gmail.com>2014-01-14 22:57:05 -0500
committermrtheb <mrlabbe@gmail.com>2014-01-14 22:57:05 -0500
commitfb4903e518d2fde3c01f629f6f24f0598399932c (patch)
tree8356bc8847a69db425a5d942fa95354348b3c117 /kafka/consumer.py
parent9644166048d6fe1cdbd1fc3096329ee2142b147e (diff)
parentceee715fc7bf17b28ff5a10f1f7decc8974f6506 (diff)
downloadkafka-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.py8
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()