summaryrefslogtreecommitdiff
path: root/kafka/producer/base.py
Commit message (Collapse)AuthorAgeFilesLines
...
* Fix import error in kafka/producer/base.pyDana Powers2015-06-061-1/+1
|
* Check response.error for async producerViktor Shlapakov2015-06-031-19/+24
|
* Async producer: py2.6 backward compatibility fixViktor Shlapakov2015-06-031-2/+2
|
* Improve async producer code: logic and style fixesViktor Shlapakov2015-06-031-24/+33
| | | | | | | | | | - send_producer_request with fail_on_error=False to retry failed reqs only - using an internal dict with with namedtuple keys for retry counters - refresh metadata on refresh_error irrespective to retries options - removed infinite retries (retry_options.limit=None) as an over-feature - separate producer init args for retries options (limit,backoff,on_timeouts) - AsyncProducerQueueFull returns a list of failed messages - producer tests improved thanks to @rogaha and @toli
* Change backoff message log levelViktor Shlapakov2015-06-031-1/+1
|
* Fix async producer queue put argumentsViktor Shlapakov2015-06-031-2/+4
|
* Fix names for async retries opts, add timeout for putViktor Shlapakov2015-06-031-12/+16
|
* Simplification of retry logicViktor Shlapakov2015-06-031-30/+28
|
* Fix small issues with names/testsViktor Shlapakov2015-06-031-9/+7
|
* async queue: refactored code; add one more testEduard Iskandarov2015-06-031-2/+7
|
* add producer send batch queue overfilled testИскандаров Эдуард2015-06-031-1/+7
|
* Disable retry on timeouts by default (old behaviour)Viktor Shlapakov2015-06-031-1/+1
|
* Clean and simplify retry logicViktor Shlapakov2015-06-031-60/+32
|
* Arg fixes for base/keyed producersViktor Shlapakov2015-06-031-2/+1
|
* Improved retry logicViktor Shlapakov2015-06-031-21/+65
|
* Fixed tests and other issues after rebaseViktor Shlapakov2015-06-031-1/+1
|
* Returned default behaviour with no retriesViktor Shlapakov2015-06-031-1/+1
|
* Fix: check failed reqs to retry only for positive limitViktor Shlapakov2015-06-031-3/+3
|
* Fixed compatible issues with testsViktor Shlapakov2015-06-031-3/+5
|
* Producer _send_upstream fixes, added tests for retriesViktor Shlapakov2015-06-031-6/+20
|
* Fixed base producer importsViktor Shlapakov2015-06-031-1/+2
|
* Retries for async batchingViktor Shlapakov2015-06-031-7/+24
|
* Merge pull request #360 from dpkp/atexit_cleanupDana Powers2015-04-041-1/+26
|\ | | | | Register atexit handlers for consumer and producer thread/multiprocess cleanup
| * Register atexit handlers for consumer and producer thread/multiprocess ↵Dana Powers2015-03-311-1/+26
| | | | | | | | cleanup (not __del__)
* | Make external API consistently support python3 strings for topic.Space2015-04-031-0/+6
|/
* Merge pull request #329 from vshlapakov/feature-batch-msg-keysDana Powers2015-03-291-2/+2
|\ | | | | Correct message keys for async batching mode
| * Correct message keys for async batching modeViktor Shlapakov2015-02-251-2/+2
| |
* | Merge branch 'vshlapakov-feature-async-threading'Dana Powers2015-03-081-26/+26
|\ \ | | | | | | | | | | | | | | | | | | PR 330: Threading for async batching Conflicts: kafka/producer/base.py
| * | Async producer stop() fixViktor Shlapakov2015-02-261-2/+2
| | |
| * | Using threading.Event to stop async producer threadViktor Shlapakov2015-02-261-5/+10
| | |
| * | Returned original tests, rm dirty flag, name fixesViktor Shlapakov2015-02-251-24/+17
| | |
| * | Trying to use threading for async batchingViktor Shlapakov2015-02-251-3/+5
| |/
* | Stopping daemonized threads when references to these threads are lostChristophe-Marie Duquesne2015-03-021-0/+6
|/
* Add Sphinx API docsWill Daly2015-01-151-10/+10
|
* Added raise of TypeError for non bytes keyLou Marvin Caraig2014-11-261-1/+6
|
* Key is passed when creating messages for both async=False and async=TrueLou Marvin Caraig2014-11-261-5/+6
|
* Added private method _send_messages that can accept kwargsLou Marvin Caraig2014-11-261-0/+2
|
* Separate consumers/producers/partitionersDana Powers2014-09-101-0/+206
View Lorry Controller Status