| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Improve error handling and tests w.r.t. codecs | Patrick Lucas | 2014-05-07 | 1 | -1/+18 |
| | | | | | | | | | | | Add function kafka.protocol.create_message_set() that takes a list of payloads and a codec and returns a message set with the desired encoding. Introduce kafka.common.UnsupportedCodecError, raised if an unknown codec is specified. Include a test for the new function. | ||||
| * | Merge branch 'teach_producers_about_compression' into producer_compression | Mark Roberts | 2014-05-07 | 1 | -11/+12 |
| |\ | | | | | | | | | | | Conflicts: servers/0.8.0/kafka-src test/test_unit.py | ||||
| | * | Add 'codec' parameter to Producer | Patrick Lucas | 2014-05-03 | 1 | -11/+12 |
| | | | | | | | | | | | Adds a codec parameter to Producer.__init__ that lets the user choose a compression codec to use for all messages sent by it. | ||||
| * | | Reinstate test_integrate, make test_protocol more explicit, create testutil | Mark Roberts | 2014-04-08 | 1 | -1/+1 |
| | | | |||||
| * | | Explicit testing of protocol errors. Make tests more explicit, and start ↵ | Mark Roberts | 2014-04-08 | 1 | -4/+3 |
| |/ | | | | working on intermittent failures in test_encode_fetch_request and test_encode_produc_request | ||||
| * | Merge pull request #98 from waliaashish85/dev | Omar | 2014-01-16 | 1 | -4/+2 |
| |\ | | | | | Changes for aligning code with offset fetch and commit APIs (Kafka 0.8.1) | ||||
| | * | Deleting client_id from offset commit and fetch response as per Kafka trunk code | Ashish Walia | 2014-01-13 | 1 | -2/+0 |
| | | | |||||
| | * | Syncing offset commit and fetch api keys with Kafka trunk code | Ashish Walia | 2014-01-13 | 1 | -2/+2 |
| | | | |||||
| * | | Add note about questionable error handling while decoding messages. | Omar Ghishan | 2014-01-06 | 1 | -0/+8 |
| | | | | | | | | | Will remove once any error handling issues are resolved. | ||||
| * | | Add and fix comments to protocol.py | Omar Ghishan | 2014-01-06 | 1 | -6/+10 |
| |/ | |||||
| * | 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 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |