File tree 2 files changed +60
-0
lines changed
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
+
1
28
# 1.0.0 (Feb 15, 2016)
2
29
3
30
This release includes significant code changes. Users of older kafka-python
Original file line number Diff line number Diff line change 1
1
Changelog
2
2
=========
3
3
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
+
4
37
1.0.0 (Feb 15, 2016)
5
38
####################
6
39
You can’t perform that action at this time.
0 commit comments