Commits

Branch selector

 async_producer_stop

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 5, 2015

• Producer.stop() now blocks until async thread completes (drop confusing timeout arg)

  

  Dana Powers

  committed
  5682ff6

  Copy full SHA for 5682ff6

• Revert broken send_produce_request try/except from PR 467 (resps=None)

  

  Dana Powers

  committed
  2916bb8

  Copy full SHA for 2916bb8

• Use producer.stop() to flush messages in async producer test

  

  Dana Powers

  committed
  b687b4c

  Copy full SHA for b687b4c

• Fix requestId handling in send_broker_aware_request

  

  Dana Powers

  committed
  0ab97a9

  Copy full SHA for 0ab97a9

• Cleanup new producer tests...

  

  Dana Powers

  committed
  fb02435

  Copy full SHA for fb02435

• client.reinit() can raise an exception; catch in async producer

  

  Dana Powers

  committed
  7dec992

  Copy full SHA for 7dec992

Commits on Dec 4, 2015

• Update kafka broker list for travis testing (add 0.9.0.0, bump 0.8.2.2)

  

  Dana Powers

  committed
  8a74c20

  Copy full SHA for 8a74c20

• Update setup.py to show python 3.5 compatibility explicitly

  

  Dana Powers

  committed
  25a220f

  Copy full SHA for 25a220f

• Add py35 to tox testing

  Show description for 71a7891
  

  Dana Powers

  committed
  71a7891

  Copy full SHA for 71a7891

• Cache pip and servers/ for travis builds

  

  Dana Powers

  committed
  7355bf4

  Copy full SHA for 7355bf4

• Update travis config to use container infrastructure

  

  Dana Powers

  committed
  e289ab5

  Copy full SHA for e289ab5

• Add 0.8.2.2 and 0.9.0.0 resources for integration tests; update default official releases

  

  Dana Powers

  committed
  eab0a55

  Copy full SHA for eab0a55

Commits on Dec 3, 2015

• Update docs and links wrt maintainer change (mumrah -> dpkp)

  

  Dana Powers

  committed
  770a9bb

  Copy full SHA for 770a9bb

• Merge pull request #481 from zackdever/pylint-1.5-changes

  Show description for 63b0e61
  dpkp

  committed
  63b0e61

  Copy full SHA for 63b0e61

• new pylint disables for pylint 1.5.1

  Show description for 16f6154
  zackdever

  committed
  16f6154

  Copy full SHA for 16f6154

Commits on Dec 2, 2015

• Merge pull request #420 from toddpalino/master

  Show description for 3e28b42
  dpkp

  committed
  3e28b42

  Copy full SHA for 3e28b42

• Fix python3 / python2 comments re queue/Queue

  

  Dana Powers

  committed
  ee6b9cb

  Copy full SHA for ee6b9cb

• Add Murmur2Partitioner to kafka __all__ imports - fix issue 471

  

  Dana Powers

  committed
  cfbdc05

  Copy full SHA for cfbdc05

• Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requests

  Show description for 58e2ab4
  dpkp

  committed
  58e2ab4

  Copy full SHA for 58e2ab4

• Merge pull request #467 from bschopman/master

  Show description for cdcaea6
  dpkp

  committed
  cdcaea6

  Copy full SHA for cdcaea6

• Merge pull request #457 from saaros/block-for-number-of-messages

  Show description for 2eca553
  dpkp

  committed
  2eca553

  Copy full SHA for 2eca553

• Merge pull request #446 from zackdever/consumer-class-configs

  Show description for c2eccd5
  dpkp

  committed
  c2eccd5

  Copy full SHA for c2eccd5

• Merge pull request #456 from barricadeio/mp-retry

  Show description for da21744
  dpkp

  committed
  da21744

  Copy full SHA for da21744

• Merge pull request #454 from trbs/gzip_compressionlevel

  Show description for a0f103e
  dpkp

  committed
  a0f103e

  Copy full SHA for a0f103e

• Merge pull request #441 from koobs/patch-1

  Show description for 20df6cd
  dpkp

  committed
  20df6cd

  Copy full SHA for 20df6cd

• Merge pull request #439 from chrischamberlin/fix-murmur

  Show description for 4fc15a5
  dpkp

  committed
  4fc15a5

  Copy full SHA for 4fc15a5

• Merge pull request #435 from docker-hub/fix-producer-cleanup-logic

  Show description for 149d43c
  dpkp

  committed
  149d43c

  Copy full SHA for 149d43c

• Merge pull request #418 from scrapinghub/mp_partition_info

  Show description for 0ba9d3d
  dpkp

  committed
  0ba9d3d

  Copy full SHA for 0ba9d3d

• Merge pull request #409 from scrapinghub/feature-allow-null-payload

  Show description for 0d41e6b
  dpkp

  committed
  0d41e6b

  Copy full SHA for 0d41e6b

Commits on Nov 11, 2015

• Add tests. Bug fix. Rename socket_conn dict.

  ecanzonieri

  committed
  c2adeea

  Copy full SHA for c2adeea

• Unblocking broker aware request

  ecanzonieri

  committed
  04920bb

  Copy full SHA for 04920bb

Commits on Oct 22, 2015

• Prevents crashing communication thread of async producer

  Show description for 64cda81
  

  Balthasar Schopman

  committed
  64cda81

  Copy full SHA for 64cda81

Commits on Oct 7, 2015

• Merge pull request #436 from mutability/async-catch-unavailable-error

  Show description for e99a934
  dpkp

  committed
  e99a934

  Copy full SHA for e99a934

Commits on Sep 18, 2015

• Consumers get_messages: allow blocking until some messages are received

  Show description for e74a8ba
  saaros

  committed
  e74a8ba

  Copy full SHA for e74a8ba

Commits on Sep 14, 2015

• Support retry semantics in MultiProcessConsumer

  duggan

  committed
  7e19de5

  Copy full SHA for 7e19de5

Pagination

Previous

Next