Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | flake8 pass (pep8 and pyflakes) | mrtheb | 2013-10-03 | 1 | -19/+19 |
| | |||||
* | style: remove extra brackets | Vetoshkin Nikita | 2013-10-03 | 1 | -1/+1 |
| | |||||
* | style: fix camelCase variable names | Vetoshkin Nikita | 2013-10-03 | 1 | -13/+13 |
| | | | | | | Conflicts: kafka/util.py | ||||
* | Fix #44 Add missing exception classv0.8.0 | David Arthur | 2013-09-24 | 1 | -3/+3 |
| | | | | Also move the exceptions to common instead of util | ||||
* | Auto-adjusting consumer fetch size | David Arthur | 2013-09-09 | 1 | -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 files | Mahendra M | 2013-05-29 | 1 | -65/+166 |
| | | | | consumer.py and conn.py will be done later after pending merges | ||||
* | A few fixes for offset APIs in 0.8.1 | David Arthur | 2013-04-02 | 1 | -2/+0 |
| | |||||
* | Refactoring a bit, cleanup for 0.8 | David Arthur | 2013-04-02 | 1 | -1/+1 |
| | | | | Marking some stuff as not compatible for 0.8 (will be added in 0.8.1) | ||||
* | Big code re-org | David Arthur | 2013-04-02 | 1 | -0/+457 |