delta/python-packages/kafka-python.git/kafka/producer/keyed.py, branch protocol_parser

Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topics

2016-03-13T16:35:49+00:00

Drop kafka_bytestring

2015-12-11T02:37:03+00:00

Dont maintain all producer args / kwargs in subclass init and docstrings -- just refer to super class (Producer)

2015-06-09T01:59:23+00:00

Merge pull request #379 from dpkp/deprecate_keyed_producer_send

2015-06-08T23:07:57+00:00

Deprecate KeyedProducer.send in favor of send_messages

Deprecate async producer batch_send kwarg -- use 'async' instead

2015-06-07T02:27:56+00:00

Use separate module loggers instead of a single 'kafka' logger

2015-06-06T23:11:20+00:00

Improve async producer code: logic and style fixes

2015-06-03T08:22:49+00:00

- 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

2015-06-03T08:22:48+00:00

Arg fixes for base/keyed producers

2015-06-03T08:22:47+00:00

Improved retry logic