diff options
| author | David Arthur <mumrah@gmail.com> | 2013-04-01 14:56:59 -0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2013-04-02 20:19:30 -0400 |
| commit | 0678a452ca7ad5fba8e947cbfcf8fcb0f87b902c (patch) | |
| tree | d4011fc89717f1eb9884787ae333be5b525bacd4 /kafka/producer.py | |
| parent | b6d98c07b418b16061ae92392947d5dd6958a708 (diff) | |
| download | kafka-python-0678a452ca7ad5fba8e947cbfcf8fcb0f87b902c.tar.gz | |
Refactoring a bit, cleanup for 0.8
Marking some stuff as not compatible for 0.8 (will be added in 0.8.1)
Diffstat (limited to 'kafka/producer.py')
| -rw-r--r-- | kafka/producer.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/kafka/producer.py b/kafka/producer.py index 823d923..93d6e3b 100644 --- a/kafka/producer.py +++ b/kafka/producer.py @@ -13,10 +13,11 @@ class SimpleProducer(object): def __init__(self, client, topic): self.client = client self.topic = topic - self.client.load_metadata_for_topics(topic) + self.client._load_metadata_for_topics(topic) self.next_partition = cycle(self.client.topic_partitions[topic]) def send_message(self, msg): req = ProduceRequest(self.topic, self.next_partition.next(), messages=[create_message(msg)]) - resp = self.client.send_produce_request([req]).next() + resp = self.client.send_produce_request([req])[0] + assert resp.error == 0 |