File tree Expand file tree Collapse file tree 2 files changed +60
-0
lines changed Expand file tree Collapse file tree 2 files changed +60
-0
lines changed Original file line number Diff line number Diff line change 1+ # 1.0.1 (Unreleased)
2+
3+ Consumers
4+ * Add RangePartitionAssignor (and use as default); add assignor tests (dpkp PR 550)
5+ * Make sure all consumers are in same generation before stopping group test
6+ * Verify node ready before sending offset fetch request from coordinator
7+ * Improve warning when offset fetch request returns unknown topic / partition
8+
9+ Producers
10+ * Warn if pending batches failed during flush
11+ * Fix concurrency bug in RecordAccumulator.ready()
12+ * Fix bug in SimpleBufferPool memory condition waiting / timeout
13+ * Support batch_size = 0 in producer buffers (dpkp PR 558)
14+ * Catch duplicate batch.done() calls [ e.g., maybe_expire then a response errback]
15+
16+ Clients
17+
18+ Documentation
19+ * Improve kafka.cluster docstrings
20+ * Migrate load_example.py to KafkaProducer / KafkaConsumer
21+
22+ Internals
23+ * Dont override system rcvbuf or sndbuf unless configured explicitly (dpkp PR 557)
24+ * Some attributes may not exist in __ del__ if we failed assertions
25+ * Break up some circular references and close client wake pipes on __ del__ (aisch PR 554)
26+
27+
128# 1.0.0 (Feb 15, 2016)
229
330This release includes significant code changes. Users of older kafka-python
Original file line number Diff line number Diff line change 11Changelog
22=========
33
4+ 1.0.1 (Unreleased)
5+ ####################
6+
7+ Consumers
8+ ---------
9+ * Add RangePartitionAssignor (and use as default); add assignor tests (dpkp PR 550)
10+ * Make sure all consumers are in same generation before stopping group test
11+ * Verify node ready before sending offset fetch request from coordinator
12+ * Improve warning when offset fetch request returns unknown topic / partition
13+
14+ Producers
15+ ---------
16+ * Warn if pending batches failed during flush
17+ * Fix concurrency bug in RecordAccumulator.ready()
18+ * Fix bug in SimpleBufferPool memory condition waiting / timeout
19+ * Support batch_size = 0 in producer buffers (dpkp PR 558)
20+ * Catch duplicate batch.done() calls [e.g., maybe_expire then a response errback]
21+
22+ Clients
23+ -------
24+
25+ Documentation
26+ -------------
27+ * Improve kafka.cluster docstrings
28+ * Migrate load_example.py to KafkaProducer / KafkaConsumer
29+
30+ Internals
31+ ---------
32+ * Dont override system rcvbuf or sndbuf unless configured explicitly (dpkp PR 557)
33+ * Some attributes may not exist in __del__ if we failed assertions
34+ * Break up some circular references and close client wake pipes on __del__ (aisch PR 554)
35+
36+
4371.0.0 (Feb 15, 2016)
538####################
639
You can’t perform that action at this time.
0 commit comments