diff options
| author | David Arthur <mumrah@gmail.com> | 2012-10-02 20:26:12 -0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2012-10-02 20:26:12 -0400 |
| commit | d9aafb14c24e92a114a5e5a6c2de284e22d6e01b (patch) | |
| tree | 3736e1c4f9ab7d9c9303012640652120e2ffa2ad /kafka/client.py | |
| parent | cab6fee1e76fa133898e9c9570da6d432066d1c3 (diff) | |
| download | kafka-python-d9aafb14c24e92a114a5e5a6c2de284e22d6e01b.tar.gz | |
Isn't it nice when tests actually find bugs
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/kafka/client.py b/kafka/client.py index 0cde87f..ad80773 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -454,7 +454,6 @@ class KafkaClient(object): if sent == 0: raise RuntimeError("Kafka went away") - def send_multi_message_set(self, produceRequests): """ Send a MultiProduceRequest @@ -550,8 +549,8 @@ class KafkaClient(object): <offset> ::= <int64> """ - req = length_prefix_message(encode_offset_request(offsetRequest)) - log.debug("Sending %d bytes to Kafka", len(req)) + req = length_prefix_message(self.encode_offset_request(offsetRequest)) + log.debug("Sending OffsetRequest of %d bytes to Kafka", len(req)) sent = self._sock.send(req) if sent == 0: raise RuntimeError("Kafka went away") @@ -574,7 +573,7 @@ class KafkaClient(object): topic: string payloads: strings """ - messages = tuple([create_message(payload) for payload in payloads]) + messages = tuple([self.create_message(payload) for payload in payloads]) self.send_message_set(ProduceRequest(topic, -1, messages)) def iter_messages(self, topic, partition, offset, size, auto=True): |