Fixups for PR 331 (async producer)#388

Merged

dpkp merged 12 commits intomasterfrom

331_fixups

Jun 7, 2015

Commits on Jun 7, 2015

PR 331 fixup: Fix kafka.common imports from kafka.producer.base (one import block, add ProduceResponse)
Dana Powers
committed
PR 331 fixup: fix _handle_error closure
Dana Powers
committed
PR 331 fixup: Support unlimited retries with async_retry_limit=None
Dana Powers
committed
PR 331 fixup: log warnings on async producer backoff and metadata refresh
Dana Powers
committed
PR 331 fixup: Dont need try/except when calling send_produce_requests with fail_on_error=False
Dana Powers
committed
PR 331 fixup: Rename reqs dict to request_tries
Dana Powers
committed
PR 331 fixup: do not attempt to get new messages if there are pending retries
Dana Powers
committed
Log retries and failed messages in async producer (configurable as full messages or hash())
Dana Powers
committed
Deprecate async producer batch_send kwarg -- use 'async' instead
Dana Powers
committed
Update Producer class docstring
Dana Powers
committed
Dont stop async producer until all pending messages have been processed
Dana Powers
committed
Add async_stop_timeout parameter to tune how long to let the producer
Dana Powers
committed