From 8f1384bd2343bcafd5c5582dc6061bcc45ed3635 Mon Sep 17 00:00:00 2001 From: Ryan Maclear Date: Fri, 23 Nov 2012 07:56:26 +0200 Subject: [PATCH] Changing default partion in simple message to 0 --- kafka/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/client.py b/kafka/client.py index c25e2d2bd..ad2a243e5 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -596,7 +596,7 @@ def send_messages_simple(self, topic, *payloads): payloads: strings """ messages = tuple([self.create_message(payload) for payload in payloads]) - self.send_message_set(ProduceRequest(topic, -1, messages)) + self.send_message_set(ProduceRequest(topic, 0, messages)) def iter_messages(self, topic, partition, offset, size, auto=True): """