summaryrefslogtreecommitdiff
path: root/kafka/producer/keyed.py
Commit message (Collapse)AuthorAgeFilesLines
* Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topicsDana Powers2016-03-131-1/+1
|
* Drop kafka_bytestringDana Powers2015-12-101-2/+0
|
* Dont maintain all producer args / kwargs in subclass __init__ and docstrings ↵Dana Powers2015-06-081-43/+10
| | | | -- just refer to super class (Producer)
* Merge pull request #379 from dpkp/deprecate_keyed_producer_sendDana Powers2015-06-081-5/+6
|\ | | | | Deprecate KeyedProducer.send in favor of send_messages
| * Deprecate KeyedProducer.send in favor of send_messages -- keep interface ↵Dana Powers2015-05-171-5/+6
| | | | | | | | consistent
* | Deprecate async producer batch_send kwarg -- use 'async' insteadDana Powers2015-06-061-2/+2
| |
* | Use separate module loggers instead of a single 'kafka' loggerDana Powers2015-06-061-1/+1
| |
* | Improve async producer code: logic and style fixesViktor Shlapakov2015-06-031-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 putViktor Shlapakov2015-06-031-3/+8
| |
* | Arg fixes for base/keyed producersViktor Shlapakov2015-06-031-2/+1
| |
* | Improved retry logicViktor Shlapakov2015-06-031-4/+2
| |
* | Retries for async batchingViktor Shlapakov2015-06-031-3/+8
|/
* Make external API consistently support python3 strings for topic.Space2015-04-031-0/+4
|
* Always use the initial partition list when hashing keys in KeyedProducerDana Powers2015-02-091-1/+1
|
* Add Sphinx API docsWill Daly2015-01-151-10/+12
|
* added a send_messages api to KeyedProducerJordan Shaw2014-12-151-0/+4
| | | | Signed-off-by: Jordan Shaw <jordan@pubnub.com>
* Key is passed when creating messages for both async=False and async=TrueLou Marvin Caraig2014-11-261-1/+1
|
* Separate consumers/producers/partitionersDana Powers2014-09-101-0/+62