| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | add producer send batch queue overfilled test | Искандаров Эдуард | 2015-06-03 | 1 | -1/+7 | |
| | | ||||||
| * | Disable retry on timeouts by default (old behaviour) | Viktor Shlapakov | 2015-06-03 | 1 | -1/+1 | |
| | | ||||||
| * | Clean and simplify retry logic | Viktor Shlapakov | 2015-06-03 | 1 | -60/+32 | |
| | | ||||||
| * | Arg fixes for base/keyed producers | Viktor Shlapakov | 2015-06-03 | 1 | -2/+1 | |
| | | ||||||
| * | Improved retry logic | Viktor Shlapakov | 2015-06-03 | 1 | -21/+65 | |
| | | ||||||
| * | Fixed tests and other issues after rebase | Viktor Shlapakov | 2015-06-03 | 1 | -1/+1 | |
| | | ||||||
| * | Returned default behaviour with no retries | Viktor Shlapakov | 2015-06-03 | 1 | -1/+1 | |
| | | ||||||
| * | Fix: check failed reqs to retry only for positive limit | Viktor Shlapakov | 2015-06-03 | 1 | -3/+3 | |
| | | ||||||
| * | Fixed compatible issues with tests | Viktor Shlapakov | 2015-06-03 | 1 | -3/+5 | |
| | | ||||||
| * | Producer _send_upstream fixes, added tests for retries | Viktor Shlapakov | 2015-06-03 | 1 | -6/+20 | |
| | | ||||||
| * | Fixed base producer imports | Viktor Shlapakov | 2015-06-03 | 1 | -1/+2 | |
| | | ||||||
| * | Retries for async batching | Viktor Shlapakov | 2015-06-03 | 1 | -7/+24 | |
| | | ||||||
| * | Merge pull request #360 from dpkp/atexit_cleanup | Dana Powers | 2015-04-04 | 1 | -1/+26 | |
| |\ | | | | | Register atexit handlers for consumer and producer thread/multiprocess cleanup | |||||
| | * | Register atexit handlers for consumer and producer thread/multiprocess ↵ | Dana Powers | 2015-03-31 | 1 | -1/+26 | |
| | | | | | | | | | cleanup (not __del__) | |||||
| * | | Make external API consistently support python3 strings for topic. | Space | 2015-04-03 | 1 | -0/+6 | |
| |/ | ||||||
| * | Merge pull request #329 from vshlapakov/feature-batch-msg-keys | Dana Powers | 2015-03-29 | 1 | -2/+2 | |
| |\ | | | | | Correct message keys for async batching mode | |||||
| | * | Correct message keys for async batching mode | Viktor Shlapakov | 2015-02-25 | 1 | -2/+2 | |
| | | | ||||||
| * | | Merge branch 'vshlapakov-feature-async-threading' | Dana Powers | 2015-03-08 | 1 | -26/+26 | |
| |\ \ | | | | | | | | | | | | | | | | | | | PR 330: Threading for async batching Conflicts: kafka/producer/base.py | |||||
| | * | | Async producer stop() fix | Viktor Shlapakov | 2015-02-26 | 1 | -2/+2 | |
| | | | | ||||||
| | * | | Using threading.Event to stop async producer thread | Viktor Shlapakov | 2015-02-26 | 1 | -5/+10 | |
| | | | | ||||||
| | * | | Returned original tests, rm dirty flag, name fixes | Viktor Shlapakov | 2015-02-25 | 1 | -24/+17 | |
| | | | | ||||||
| | * | | Trying to use threading for async batching | Viktor Shlapakov | 2015-02-25 | 1 | -3/+5 | |
| | |/ | ||||||
| * | | Stopping daemonized threads when references to these threads are lost | Christophe-Marie Duquesne | 2015-03-02 | 1 | -0/+6 | |
| |/ | ||||||
| * | Add Sphinx API docs | Will Daly | 2015-01-15 | 1 | -10/+10 | |
| | | ||||||
| * | Added raise of TypeError for non bytes key | Lou Marvin Caraig | 2014-11-26 | 1 | -1/+6 | |
| | | ||||||
| * | Key is passed when creating messages for both async=False and async=True | Lou Marvin Caraig | 2014-11-26 | 1 | -5/+6 | |
| | | ||||||
| * | Added private method _send_messages that can accept kwargs | Lou Marvin Caraig | 2014-11-26 | 1 | -0/+2 | |
| | | ||||||
| * | Separate consumers/producers/partitioners | Dana Powers | 2014-09-10 | 1 | -0/+206 | |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |