| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Finish breaking out integration tests | Mark Roberts | 2014-04-17 | 1 | -931/+0 |
| | | |||||
| * | Reinstate test_integrate, make test_protocol more explicit, create testutil | Mark Roberts | 2014-04-08 | 1 | -936/+931 |
| | | |||||
| * | Comment out all of test_integration because it currently does not work | Mark Roberts | 2014-04-08 | 1 | -936/+936 |
| | | |||||
| * | Support list (or comma-separated) of hosts (replaces host and port arguments) | mrtheb | 2014-02-09 | 1 | -13/+13 |
| | | |||||
| * | Merge branch 'master' into multihosts | mrtheb | 2014-01-31 | 1 | -137/+181 |
| |\ | | | | | | | | | | | | | | | | | Conflicts: kafka/client.py kafka/conn.py setup.py test/test_integration.py test/test_unit.py | ||||
| | * | Make producers take a topic argument at send rather than init time | Omar Ghishan | 2014-01-23 | 1 | -41/+41 |
| | | | | | | | | | This allows a single producer to be used to send to multiple topics. See https://github.com/mumrah/kafka-python/issues/110 | ||||
| | * | Make integration test warming more intuitive | Thomas Dimson | 2014-01-14 | 1 | -91/+86 |
| | | | |||||
| | * | Add a few 9s test_multi_process_consumer, make clear what setUp is doing | Thomas Dimson | 2014-01-13 | 1 | -13/+17 |
| | | | |||||
| | * | Exception hierarchy, invalidate more md on errors | Thomas Dimson | 2014-01-13 | 1 | -27/+45 |
| | | | |||||
| | * | Some cleanup and easier to read test fixture output | Omar Ghishan | 2014-01-07 | 1 | -1/+1 |
| | | | |||||
| | * | Make kafka brokers per-test in failover integration tests | Omar Ghishan | 2014-01-06 | 1 | -13/+11 |
| | | | | | | | | | | | This is better since the tests stop/start brokers, and if something goes wrong they can affect eachother. | ||||
| | * | Add tests for limited and unlimited consumer max_buffer_size | Omar Ghishan | 2014-01-06 | 1 | -1/+25 |
| | | | |||||
| | * | Fix client and consumer params in integration tests | Omar Ghishan | 2014-01-06 | 1 | -6/+12 |
| | | | |||||
| * | | Allow KafkaClient to take in a list of brokers for bootstrapping | Marc Labbe | 2013-11-14 | 1 | -9/+14 |
| |/ | |||||
| * | make changes to be more fault tolerant: clean up connections, brokers, ↵ | Jim Lim | 2013-10-04 | 1 | -0/+107 |
| | | | | | | | | | failed_messages - add integration tests for sync producer - add integration tests for async producer w. leadership election - use log.exception | ||||
| * | Cherry-pick mrtheb/kafka-python 8b9c7e51 | mrtheb | 2013-10-03 | 1 | -12/+20 |
| | | | | | | | | | | Sync tests and fixtures with kafka 0.8.0-beta1 tag Conflicts: README.md kafka-src | ||||
| * | Auto-adjusting consumer fetch size | David Arthur | 2013-09-09 | 1 | -12/+6 |
| | | | | | | | | | | | | | | | | 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 | ||||
| * | Fixed #42, make fetch size configurable | David Arthur | 2013-09-08 | 1 | -0/+34 |
| | | | | | | | | | | | Was hard coded to 1024 bytes which meant that larger messages were unconsumable since they would always get split causing the consumer to stop. It would probably be best to automatically retry truncated messages with a larger request size so you don't have to know your max message size ahead of time | ||||
| * | Merge branch 'issue-35' | David Arthur | 2013-07-26 | 1 | -9/+120 |
| |\ | | | | | | | | | | | | | Conflicts: kafka/__init__.py kafka/consumer.py test/test_integration.py | ||||
| | * | Test cases for multi-process consumer and blocking APIs | Mahendra M | 2013-06-27 | 1 | -9/+120 |
| | | | |||||
| * | | Test cases for new producer | Mahendra M | 2013-06-27 | 1 | -3/+274 |
| |/ | |||||
| * | Split fixtures out to a separate file | Ivan Pouzyrevsky | 2013-06-07 | 1 | -314/+2 |
| | | |||||
| * | Adhere to common python naming conventions | Ivan Pouzyrevsky | 2013-06-07 | 1 | -0/+674 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |