Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 7, 2015

• Respawn crashed services in test/service.py, rather than raise RuntimeError

  

  Dana Powers

  committed
  b1aad92

  Copy full SHA for b1aad92

• Merge pull request #388 from dpkp/331_fixups

  Show description for f32009c
  dpkp

  committed
  f32009c

  Copy full SHA for f32009c

• 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

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

  

  Dana Powers

  committed
  2ba22bf

  Copy full SHA for 2ba22bf

• Update Producer class docstring

  

  Dana Powers

  committed
  c76bc9d

  Copy full SHA for c76bc9d

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

  

  Dana Powers

  committed
  aa217e0

  Copy full SHA for aa217e0

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

  

  Dana Powers

  committed
  0f1579b

  Copy full SHA for 0f1579b

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

  

  Dana Powers

  committed
  9712f61

  Copy full SHA for 9712f61

• PR 331 fixup: Rename reqs dict to request_tries

  

  Dana Powers

  committed
  794ab5b

  Copy full SHA for 794ab5b

• 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: log warnings on async producer backoff and metadata refresh

  

  Dana Powers

  committed
  48e2789

  Copy full SHA for 48e2789

• 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: fix _handle_error closure

  

  Dana Powers

  committed
  6faa7c0

  Copy full SHA for 6faa7c0

• 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

• Encode random_message strings to bytes in test_failover_integration

  

  Dana Powers

  committed
  87bea90

  Copy full SHA for 87bea90

• KafkaClient should try/except ConnnectionError when calling _get_conn

  

  Dana Powers

  committed
  3085faa

  Copy full SHA for 3085faa

Commits on Jun 6, 2015

• Small hanging indent style nits in some producer integration tests

  

  Dana Powers

  committed
  679bf2f

  Copy full SHA for 679bf2f

• Sleep for 500ms before retrying consumer pending call in tests

  

  Dana Powers

  committed
  1f23a48

  Copy full SHA for 1f23a48

• test_batched_simple_producer__triggers_by_message should wait for producer queue to drain before testing messages were sent

  

  Dana Powers

  committed
  522395f

  Copy full SHA for 522395f

• Include message number in sent message value in _send_random_message

  

  Dana Powers

  committed
  7b86964

  Copy full SHA for 7b86964

• add option to check for at-least-once message delivery in failover tests

  

  Dana Powers

  committed
  26abd24

  Copy full SHA for 26abd24

• Reenable test_switch_leader_async

  

  Dana Powers

  committed
  9ac0f05

  Copy full SHA for 9ac0f05

• FailedPayloadsError now only has a single payload; use .payload attribute

  Show description for e16541e
  

  Dana Powers

  committed
  e16541e

  Copy full SHA for e16541e

• random_string helper should return str not bytes

  

  Dana Powers

  committed
  207499b

  Copy full SHA for 207499b

• Raise an error if we attempt to group duplicate topic-partition payloads

  Show description for 868115c
  

  Dana Powers

  committed
  868115c

  Copy full SHA for 868115c

• Module loggers in test/fixtures and test/service

  

  Dana Powers

  committed
  3a4ceef

  Copy full SHA for 3a4ceef

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

  

  Dana Powers

  committed
  5d9b174

  Copy full SHA for 5d9b174

• Fix import error in kafka/producer/base.py

  

  Dana Powers

  committed
  6406747

  Copy full SHA for 6406747

Commits on Jun 4, 2015

• Merge pull request #387 from dpkp/no_runtime_version_check

  Show description for cef5cb5
  dpkp

  committed
  cef5cb5

  Copy full SHA for cef5cb5

• Set __version__ string in kafka/version.py

  

  Dana Powers

  committed
  ded79e8

  Copy full SHA for ded79e8

• Merge pull request #331 from vshlapakov/feature-producer-retries

  Show description for 474aeaa
  dpkp

  committed
  474aeaa

  Copy full SHA for 474aeaa

Commits on Jun 3, 2015

• Check response.error for async producer

  vshlapakov

  committed
  7d6f3f5

  Copy full SHA for 7d6f3f5

• Async producer: py2.6 backward compatibility fix

  vshlapakov

  committed
  4474a50

  Copy full SHA for 4474a50

• Improve async producer code: logic and style fixes

  Show description for a3fb322
  vshlapakov

  committed
  a3fb322

  Copy full SHA for a3fb322

• Increase producer test timeout

  vshlapakov

  committed
  4c682f3

  Copy full SHA for 4c682f3

Pagination

Previous

Next