summaryrefslogtreecommitdiff
path: root/kafka/protocol.py
Commit message (Expand)AuthorAgeFilesLines
* Rename kafka.protocol -> kafka.protocol.legacyDana Powers2015-12-041-646/+0
* Merge pull request #420 from toddpalino/masterDana Powers2015-12-021-6/+47
|\
| * Support consumer metadata requeststpalino2015-07-011-6/+47
* | allow to specify compression level for codecs which support thistrbs2015-09-121-4/+4
|/
* Fixup for loop vars in kafka/protocol.pyDana Powers2015-06-081-14/+14
* Use separate module loggers instead of a single 'kafka' loggerDana Powers2015-06-061-1/+2
* Correct message keys for async batching modeViktor Shlapakov2015-02-251-3/+3
* Add Sphinx API docsWill Daly2015-01-151-67/+58
* Added keys to compressed messages (both gzip and snappy).Eric Hewitt2015-01-021-2/+2
* Added optional argument key to create_message_set functionLou Marvin Caraig2014-11-261-4/+4
* Use b''.join([]) instead of += to speedup codeDana Powers2014-09-101-53/+71
* Merge pull request #223 from dpkp/metadata_refactorDana Powers2014-09-081-20/+25
|\
| * Improve metadata protocol handlingDana Powers2014-09-011-20/+25
* | Update kafka.util.crc32 to unsigned everywhereMark Roberts2014-09-031-2/+2
* | Make all unit tests pass on py3.3/3.4Bruno ReniƩ2014-09-031-5/+8
|/
* Improve error handling and tests w.r.t. codecsPatrick Lucas2014-05-071-1/+18
* Merge branch 'teach_producers_about_compression' into producer_compressionMark Roberts2014-05-071-11/+12
|\
| * Add 'codec' parameter to ProducerPatrick Lucas2014-05-031-11/+12
* | Reinstate test_integrate, make test_protocol more explicit, create testutilMark Roberts2014-04-081-1/+1
* | Explicit testing of protocol errors. Make tests more explicit, and start wor...Mark Roberts2014-04-081-4/+3
|/
* Merge pull request #98 from waliaashish85/devOmar2014-01-161-4/+2
|\
| * Deleting client_id from offset commit and fetch response as per Kafka trunk codeAshish Walia2014-01-131-2/+0
| * Syncing offset commit and fetch api keys with Kafka trunk codeAshish Walia2014-01-131-2/+2
* | Add note about questionable error handling while decoding messages.Omar Ghishan2014-01-061-0/+8
* | Add and fix comments to protocol.pyOmar Ghishan2014-01-061-6/+10
|/
* flake8 pass (pep8 and pyflakes)mrtheb2013-10-031-19/+19
* style: remove extra bracketsVetoshkin Nikita2013-10-031-1/+1
* style: fix camelCase variable namesVetoshkin Nikita2013-10-031-13/+13
* Fix #44 Add missing exception classv0.8.0David Arthur2013-09-241-3/+3
* Auto-adjusting consumer fetch sizeDavid Arthur2013-09-091-6/+10
* PEP8-ify most of the filesMahendra M2013-05-291-65/+166
* A few fixes for offset APIs in 0.8.1David Arthur2013-04-021-2/+0
* Refactoring a bit, cleanup for 0.8David Arthur2013-04-021-1/+1
* Big code re-orgDavid Arthur2013-04-021-0/+457