Code

Fixups for PR 331 (async producer)#388

Code

Merged

dpkp merged 12 commits intomasterdpkp/kafka-python:masterfrom 331_fixupsCopy head branch name to clipboardJun 7, 2015

+180-110

Commits

Commits on Jun 7, 2015

• PR 331 fixup: Fix kafka.common imports from kafka.producer.base (one import block, add ProduceResponse)

  

  Dana Powers

  committed
  68f5506

  Copy full SHA for 68f5506

• PR 331 fixup: fix _handle_error closure

  

  Dana Powers

  committed
  6faa7c0

  Copy full SHA for 6faa7c0

• PR 331 fixup: Support unlimited retries with async_retry_limit=None

  Show description for 3fdd7b7
  

  Dana Powers

  committed
  3fdd7b7

  Copy full SHA for 3fdd7b7

• PR 331 fixup: log warnings on async producer backoff and metadata refresh

  

  Dana Powers

  committed
  48e2789

  Copy full SHA for 48e2789

• PR 331 fixup: Dont need try/except when calling send_produce_requests with fail_on_error=False

  

  Dana Powers

  committed
  d96a9b7

  Copy full SHA for d96a9b7

• PR 331 fixup: Rename reqs dict to request_tries

  

  Dana Powers

  committed
  794ab5b

  Copy full SHA for 794ab5b

• PR 331 fixup: do not attempt to get new messages if there are pending retries

  

  Dana Powers

  committed
  9712f61

  Copy full SHA for 9712f61

• Log retries and failed messages in async producer (configurable as full messages or hash())

  

  Dana Powers

  committed
  0f1579b

  Copy full SHA for 0f1579b

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

  

  Dana Powers

  committed
  aa217e0

  Copy full SHA for aa217e0

• Update Producer class docstring

  

  Dana Powers

  committed
  c76bc9d

  Copy full SHA for c76bc9d

• Dont stop async producer until all pending messages have been processed

  

  Dana Powers

  committed
  2ba22bf

  Copy full SHA for 2ba22bf

• Add async_stop_timeout parameter to tune how long to let the producer

  Show description for 1d5f4b1
  

  Dana Powers

  committed
  1d5f4b1

  Copy full SHA for 1d5f4b1