From 685012861893b104f8cdce159297ee9e8d849c0e Mon Sep 17 00:00:00 2001 From: Mark Roberts Date: Mon, 24 Feb 2014 23:08:03 -0800 Subject: Correct __version__ in init --- kafka/__init__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/__init__.py b/kafka/__init__.py index 73aa760..5298dbf 100644 --- a/kafka/__init__.py +++ b/kafka/__init__.py @@ -1,5 +1,5 @@ __title__ = 'kafka' -__version__ = '0.2-alpha' +__version__ = '0.8.1-1' __author__ = 'David Arthur' __license__ = 'Apache License 2.0' __copyright__ = 'Copyright 2012, David Arthur under Apache License, v2.0' -- cgit v1.2.1 From d842ced8f8dae99997f08427218a7b4f9d8b097d Mon Sep 17 00:00:00 2001 From: Mark Roberts Date: Mon, 24 Feb 2014 23:10:30 -0800 Subject: Add repr to client --- kafka/client.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/kafka/client.py b/kafka/client.py index 71ededa..a579ef3 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -186,6 +186,9 @@ class KafkaClient(object): # Order the accumulated responses by the original key order return (acc[k] for k in original_keys) if acc else () + def __repr__(self): + return '' % (self.client_id) + ################# # Public API # ################# -- cgit v1.2.1 From 976f6c0984476a366493d9c683a9cc2fe38c8951 Mon Sep 17 00:00:00 2001 From: Mark Roberts Date: Mon, 24 Feb 2014 23:14:16 -0800 Subject: Add consumer repr --- kafka/consumer.py | 8 ++++++++ 1 file changed, 8 insertions(+) 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 '' % \ + (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 '' % \ + (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 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(+) 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(-) 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