From d14552580c4d113faf9d74ce190f14774e181a9b Mon Sep 17 00:00:00 2001 From: Jordan Shaw Date: Mon, 15 Dec 2014 15:56:02 -0800 Subject: [PATCH] added a send_messages api to KeyedProducer Signed-off-by: Jordan Shaw --- kafka/producer/keyed.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/kafka/producer/keyed.py b/kafka/producer/keyed.py index 473f70a..68c70d9 100644 --- a/kafka/producer/keyed.py +++ b/kafka/producer/keyed.py @@ -54,6 +54,10 @@ class KeyedProducer(Producer): partitioner = self.partitioners[topic] return partitioner.partition(key, self.client.get_partition_ids_for_topic(topic)) + def send_messages(self,topic,key,*msg): + partition = self._next_partition(topic, key) + return self._send_messages(topic, partition, *msg,key=key) + def send(self, topic, key, msg): partition = self._next_partition(topic, key) return self._send_messages(topic, partition, msg, key=key)