delta/python-packages/kafka-python.git/kafka/producer/simple.py, branch iterator_timeout

Merge branch '0.9'

2016-01-08T02:51:14+00:00

Conflicts:
	kafka/codec.py
	kafka/version.py
	test/test_producer.py
	test/test_producer_integration.py

Handle new topic creation / LeaderNotAvailableError in initial SimpleProducer.send_messages call

2015-12-17T06:39:51+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

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

Improved retry logic

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

Retries for async batching