From 976f6c0984476a366493d9c683a9cc2fe38c8951 Mon Sep 17 00:00:00 2001
From: Mark Roberts <markroberts@kixeye.com>
Date: Mon, 24 Feb 2014 23:14:16 -0800
Subject: Add consumer repr

---
 kafka/consumer.py | 8 ++++++++
 1 file changed, 8 insertions(+)

(limited to 'kafka/consumer.py')

diff --git a/kafka/consumer.py b/kafka/consumer.py
index f2898ad..8a04c2a 100644
--- a/kafka/consumer.py
+++ b/kafka/consumer.py
@@ -230,6 +230,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
@@ -535,6 +539,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()
-- 
cgit v1.2.1