diff options
Diffstat (limited to 'kafka/producer.py')
| -rw-r--r-- | kafka/producer.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/kafka/producer.py b/kafka/producer.py index 47e690b..589eb11 100644 --- a/kafka/producer.py +++ b/kafka/producer.py @@ -6,6 +6,7 @@ from kafka.protocol import create_message log = logging.getLogger("kafka") + class SimpleProducer(object): """ A simple, round-robbin producer. Each message goes to exactly one partition @@ -18,6 +19,7 @@ class SimpleProducer(object): def send_messages(self, *msg): req = ProduceRequest(self.topic, self.next_partition.next(), - messages=[create_message(m) for m in msg]) + messages=[create_message(m) for m in msg]) + resp = self.client.send_produce_request([req])[0] assert resp.error == 0 |