diff options
| author | David Arthur <mumrah@gmail.com> | 2012-09-27 20:35:00 -0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2012-09-27 20:35:00 -0400 |
| commit | 2a332d2983ae306a692b3796e0a309a5e7504097 (patch) | |
| tree | f5fef45e65f10dc197e4fbd3faec0819eb3eada0 /kafka.py | |
| parent | 7c86d637f5b0c8088045e382055423024d734deb (diff) | |
| download | kafka-python-2a332d2983ae306a692b3796e0a309a5e7504097.tar.gz | |
Adding simple (dumb) request tests
Integration tests to come
Diffstat (limited to 'kafka.py')
| -rw-r--r-- | kafka.py | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -201,7 +201,7 @@ class KafkaClient(object): The request-key (0) is encoded as a short (int16). len is the length of the proceeding MessageSet """ (topic, partition, messages) = produceRequest - message_set = self.encode_message_set(messages) + message_set = cls.encode_message_set(messages) log.debug("Sending MessageSet: %r" % message_set) req = struct.pack('>HH%dsii%ds' % (len(topic), len(message_set)), KafkaClient.PRODUCE_KEY, len(topic), topic, partition, len(message_set), message_set) |