diff options
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 7d44f28..ec04f5f 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 @@ -473,6 +477,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 _consume(self, partitions): """ A child process worker which consumes messages based on the |