Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topics | Dana Powers | 2016-03-13 | 1 | -1/+1 |
| | |||||
* | Drop kafka_bytestring | Dana Powers | 2015-12-10 | 1 | -2/+0 |
| | |||||
* | Dont maintain all producer args / kwargs in subclass __init__ and docstrings ↵ | Dana Powers | 2015-06-08 | 1 | -43/+10 |
| | | | | -- just refer to super class (Producer) | ||||
* | Merge pull request #379 from dpkp/deprecate_keyed_producer_send | Dana Powers | 2015-06-08 | 1 | -5/+6 |
|\ | | | | | Deprecate KeyedProducer.send in favor of send_messages | ||||
| * | Deprecate KeyedProducer.send in favor of send_messages -- keep interface ↵ | Dana Powers | 2015-05-17 | 1 | -5/+6 |
| | | | | | | | | consistent | ||||
* | | Deprecate async producer batch_send kwarg -- use 'async' instead | Dana Powers | 2015-06-06 | 1 | -2/+2 |
| | | |||||
* | | Use separate module loggers instead of a single 'kafka' logger | Dana Powers | 2015-06-06 | 1 | -1/+1 |
| | | |||||
* | | Improve async producer code: logic and style fixes | Viktor Shlapakov | 2015-06-03 | 1 | -4/+8 |
| | | | | | | | | | | | | | | | | | | | | - 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 | ||||
* | | Fix names for async retries opts, add timeout for put | Viktor Shlapakov | 2015-06-03 | 1 | -3/+8 |
| | | |||||
* | | Arg fixes for base/keyed producers | Viktor Shlapakov | 2015-06-03 | 1 | -2/+1 |
| | | |||||
* | | Improved retry logic | Viktor Shlapakov | 2015-06-03 | 1 | -4/+2 |
| | | |||||
* | | Retries for async batching | Viktor Shlapakov | 2015-06-03 | 1 | -3/+8 |
|/ | |||||
* | Make external API consistently support python3 strings for topic. | Space | 2015-04-03 | 1 | -0/+4 |
| | |||||
* | Always use the initial partition list when hashing keys in KeyedProducer | Dana Powers | 2015-02-09 | 1 | -1/+1 |
| | |||||
* | Add Sphinx API docs | Will Daly | 2015-01-15 | 1 | -10/+12 |
| | |||||
* | added a send_messages api to KeyedProducer | Jordan Shaw | 2014-12-15 | 1 | -0/+4 |
| | | | | Signed-off-by: Jordan Shaw <jordan@pubnub.com> | ||||
* | Key is passed when creating messages for both async=False and async=True | Lou Marvin Caraig | 2014-11-26 | 1 | -1/+1 |
| | |||||
* | Separate consumers/producers/partitioners | Dana Powers | 2014-09-10 | 1 | -0/+62 |