diff options
Diffstat (limited to 'kafka/producer.py')
| -rw-r--r-- | kafka/producer.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/producer.py b/kafka/producer.py index 93d6e3b..47e690b 100644 --- a/kafka/producer.py +++ b/kafka/producer.py @@ -16,8 +16,8 @@ class SimpleProducer(object): self.client._load_metadata_for_topics(topic) self.next_partition = cycle(self.client.topic_partitions[topic]) - def send_message(self, msg): + def send_messages(self, *msg): req = ProduceRequest(self.topic, self.next_partition.next(), - messages=[create_message(msg)]) + messages=[create_message(m) for m in msg]) resp = self.client.send_produce_request([req])[0] assert resp.error == 0 |