From d340ad31b258843266f51a359ed32f758432a321 Mon Sep 17 00:00:00 2001 From: Mark Roberts Date: Mon, 24 Feb 2014 23:15:17 -0800 Subject: Add SimpleProducer repr --- kafka/producer.py | 3 +++ 1 file changed, 3 insertions(+) (limited to 'kafka/producer.py') diff --git a/kafka/producer.py b/kafka/producer.py index 7ef7896..cf0fc04 100644 --- a/kafka/producer.py +++ b/kafka/producer.py @@ -198,6 +198,9 @@ class SimpleProducer(Producer): partition = self.next_partition.next() return super(SimpleProducer, self).send_messages(partition, *msg) + def __repr__(self): + return '' % self.async, self.topic + class KeyedProducer(Producer): """ -- cgit v1.2.1 From f394279397559c70ade734e3598bc83362a3f262 Mon Sep 17 00:00:00 2001 From: Mark Roberts Date: Mon, 24 Feb 2014 23:16:17 -0800 Subject: Add more repr --- kafka/producer.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'kafka/producer.py') diff --git a/kafka/producer.py b/kafka/producer.py index cf0fc04..20d67fa 100644 --- a/kafka/producer.py +++ b/kafka/producer.py @@ -199,7 +199,7 @@ class SimpleProducer(Producer): return super(SimpleProducer, self).send_messages(partition, *msg) def __repr__(self): - return '' % self.async, self.topic + return '' % (self.async, self.topic) class KeyedProducer(Producer): @@ -242,3 +242,6 @@ class KeyedProducer(Producer): partitions = self.client.topic_partitions[self.topic] partition = self.partitioner.partition(key, partitions) return self.send_messages(partition, msg) + + def __repr__(self): + return '' % (self.async, self.topic) -- cgit v1.2.1