Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Feb 27, 2016

• Merge pull request #566 from mortenlj/master

  Show description for bd13924
  dpkp

  committed
  bd13924

  Copy full SHA for bd13924

Commits on Feb 26, 2016

• Fix typo ifr.future.fail => ifr.future.failure

  mortenlj

  committed
  6b02c7d

  Copy full SHA for 6b02c7d

Commits on Feb 24, 2016

• Update to Kafka 0.9.0.1 for integration testing

  dpkp

  committed
  59ac7d6

  Copy full SHA for 59ac7d6

• Merge pull request #564 from shichao-an/master

  Show description for 8e63068
  dpkp

  committed
  8e63068

  Copy full SHA for 8e63068

• Add missing imports: KafkaError

  shichao-an

  committed
  118a06f

  Copy full SHA for 118a06f

Commits on Feb 23, 2016

• Bump version for development of next release

  dpkp

  committed
  6c6ed8c

  Copy full SHA for 6c6ed8c

Commits on Feb 19, 2016

• Release 1.0.1

  dpkp

  committed
  9d4045a

  Copy full SHA for 9d4045a

• Update Changelog for 1.0.1 patch release

  dpkp

  committed
  9d81fc3

  Copy full SHA for 9d81fc3

• Mock client.ready() call to test coordinator offset fetch request

  dpkp

  committed
  29e96f8

  Copy full SHA for 29e96f8

• Migrate load_example.py to KafkaProducer / KafkaConsumer

  dpkp

  committed
  6a2466b

  Copy full SHA for 6a2466b

• Catch duplicate batch.done() calls -- this can happen if we maybe_expire then process a response errback

  dpkp

  committed
  99bc503

  Copy full SHA for 99bc503

• Warn if pending batches failed during flush

  dpkp

  committed
  642b640

  Copy full SHA for 642b640

• Fix concurrency bug in RecordAccumulator.ready()

  dpkp

  committed
  f2d10f0

  Copy full SHA for f2d10f0

• Some attributes may not exist in __del__ if we failed assertions

  dpkp

  committed
  2dd216b

  Copy full SHA for 2dd216b

• Fix bug in SimpleBufferPool memory condition waiting / timeout

  dpkp

  committed
  799f53f

  Copy full SHA for 799f53f

• More friendly warning when offset fetch request returns unknown topic / partition

  dpkp

  committed
  72fa7ef

  Copy full SHA for 72fa7ef

• Verify node ready before sending offset fetch request from coordinator

  dpkp

  committed
  6946aa2

  Copy full SHA for 6946aa2

Commits on Feb 18, 2016

• Merge pull request #558 from dpkp/batch_size_zero

  Show description for 3147dfd
  dpkp

  committed
  3147dfd

  Copy full SHA for 3147dfd

• Merge pull request #557 from dpkp/socket_buffer_size_optional

  Show description for abd50dc
  dpkp

  committed
  abd50dc

  Copy full SHA for abd50dc

• Support batch_size = 0 in producer buffers

  dpkp

  committed
  97fd705

  Copy full SHA for 97fd705

• Dont override system rcvbuf or sndbuf unless user configures explicitly

  dpkp

  committed
  9bf304a

  Copy full SHA for 9bf304a

Commits on Feb 17, 2016

• Merge pull request #553 from aisch/kafka_client_fd_leak

  Show description for bcdefd6
  dpkp

  committed
  bcdefd6

  Copy full SHA for bcdefd6

• break up some circular references and close client wake pipe on __del__

  

  aisch

  committed
  d7522b0

  Copy full SHA for d7522b0

Commits on Feb 16, 2016

• Merge pull request #550 from dpkp/range_assignor

  Show description for 9f0db5d
  dpkp

  committed
  9f0db5d

  Copy full SHA for 9f0db5d

• Add RangePartitionAssignor (and use as default); add assignor tests

  dpkp

  committed
  c8be93b

  Copy full SHA for c8be93b

• Make sure all consumers are in same generation before stopping group test

  dpkp

  committed
  d5c05c8

  Copy full SHA for d5c05c8

• Improve kafka.cluster docstrings

  dpkp

  committed
  d1daeaa

  Copy full SHA for d1daeaa

• Bump version for development

  dpkp

  committed
  3df92c9

  Copy full SHA for 3df92c9

• Release 1.0.0

  dpkp

  committed
  48421e4

  Copy full SHA for 48421e4

• bootstrap node should be last resort in least_loaded_node()

  dpkp

  committed
  660b4de

  Copy full SHA for 660b4de

• Support setting kafka instance port explicitly in fixture

  dpkp

  committed
  0d1ccc7

  Copy full SHA for 0d1ccc7

• Remove unmaintained POWERED-BY doc

  dpkp

  committed
  251d4a9

  Copy full SHA for 251d4a9

• Use KafkaProducer / KafkaConsumer in example.py

  dpkp

  committed
  432c0fe

  Copy full SHA for 432c0fe

• Cleanup docstring nested indent (acks values)

  dpkp

  committed
  405b1a5

  Copy full SHA for 405b1a5

• Add changelog to sphinx docs; remove SimpleProducer from API list and move API up in toc

  dpkp

  committed
  d14e878

  Copy full SHA for d14e878

Pagination

Previous

Next