summaryrefslogtreecommitdiff
path: root/kafka/protocol.py
Commit message (Collapse)AuthorAgeFilesLines
* 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
| | | | | | Conflicts: kafka/util.py
* Fix #44 Add missing exception classv0.8.0David Arthur2013-09-241-3/+3
| | | | Also move the exceptions to common instead of util
* Auto-adjusting consumer fetch sizeDavid Arthur2013-09-091-6/+10
| | | | | | | | | | | | | | | Related to #42 Adds new ConsumerFetchSizeTooSmall exception that is thrown when `_decode_message_set_iter` gets a BufferUnderflowError but has not yet yielded a message In this event, SimpleConsumer will increase the fetch size by 1.5 and continue the fetching loop while _not_ increasing the offset (basically just retries the request with a larger fetch size) Once the consumer fetch size has been increased, it will remain increased while SimpleConsumer fetches from that partition
* PEP8-ify most of the filesMahendra M2013-05-291-65/+166
| | | | consumer.py and conn.py will be done later after pending merges
* 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
| | | | Marking some stuff as not compatible for 0.8 (will be added in 0.8.1)
* Big code re-orgDavid Arthur2013-04-021-0/+457