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

Be explicit with tuples for %s formatting

2018-11-18T08:21:18+00:00

Fix #1633

Change SimpleProducer to use async_send (async is reserved in py37) (#1454)

2018-03-23T12:58:55+00:00

use absolute imports everywhere (#1362)

2018-02-06T20:10:45+00:00

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