diff options
| -rw-r--r-- | CHANGES.md | 27 | ||||
| -rw-r--r-- | docs/changelog.rst | 33 |
2 files changed, 60 insertions, 0 deletions
@@ -1,3 +1,30 @@ +# 1.0.1 (Unreleased) + +Consumers +* Add RangePartitionAssignor (and use as default); add assignor tests (dpkp PR 550) +* Make sure all consumers are in same generation before stopping group test +* Verify node ready before sending offset fetch request from coordinator +* Improve warning when offset fetch request returns unknown topic / partition + +Producers +* Warn if pending batches failed during flush +* Fix concurrency bug in RecordAccumulator.ready() +* Fix bug in SimpleBufferPool memory condition waiting / timeout +* Support batch_size = 0 in producer buffers (dpkp PR 558) +* Catch duplicate batch.done() calls [e.g., maybe_expire then a response errback] + +Clients + +Documentation +* Improve kafka.cluster docstrings +* Migrate load_example.py to KafkaProducer / KafkaConsumer + +Internals +* Dont override system rcvbuf or sndbuf unless configured explicitly (dpkp PR 557) +* Some attributes may not exist in __del__ if we failed assertions +* Break up some circular references and close client wake pipes on __del__ (aisch PR 554) + + # 1.0.0 (Feb 15, 2016) This release includes significant code changes. Users of older kafka-python diff --git a/docs/changelog.rst b/docs/changelog.rst index c114fd6..dd58d81 100644 --- a/docs/changelog.rst +++ b/docs/changelog.rst @@ -1,6 +1,39 @@ Changelog ========= +1.0.1 (Unreleased) +#################### + +Consumers +--------- +* Add RangePartitionAssignor (and use as default); add assignor tests (dpkp PR 550) +* Make sure all consumers are in same generation before stopping group test +* Verify node ready before sending offset fetch request from coordinator +* Improve warning when offset fetch request returns unknown topic / partition + +Producers +--------- +* Warn if pending batches failed during flush +* Fix concurrency bug in RecordAccumulator.ready() +* Fix bug in SimpleBufferPool memory condition waiting / timeout +* Support batch_size = 0 in producer buffers (dpkp PR 558) +* Catch duplicate batch.done() calls [e.g., maybe_expire then a response errback] + +Clients +------- + +Documentation +------------- +* Improve kafka.cluster docstrings +* Migrate load_example.py to KafkaProducer / KafkaConsumer + +Internals +--------- +* Dont override system rcvbuf or sndbuf unless configured explicitly (dpkp PR 557) +* Some attributes may not exist in __del__ if we failed assertions +* Break up some circular references and close client wake pipes on __del__ (aisch PR 554) + + 1.0.0 (Feb 15, 2016) #################### |