1
- # Unreleased
1
+ # 1.4.4 (Nov 20, 2018)
2
2
3
3
Bugfixes
4
4
* (Attempt to) Fix deadlock between consumer and heartbeat (zhgjun / dpkp #1628 )
5
5
* Fix Metrics dict memory leak (kishorenc #1569 )
6
6
7
7
Client
8
8
* Support Kafka record headers (hnousiainen #1574 )
9
- * Add KafkaAdmin class (llamahunter #1540 )
10
9
* Set socket timeout for the write-side of wake socketpair (Fleurer #1577 )
11
10
* Add kerberos domain name config for gssapi sasl mechanism handshake (the-sea #1542 )
12
11
* Support smaller topic metadata fetch during bootstrap (andyxning #1541 )
12
+ * Use TypeError for invalid timeout type (jeffwidman #1636 )
13
+ * Break poll if closed (dpkp)
14
+
15
+ Admin Client
16
+ * Add KafkaAdminClient class (llamahunter #1540 )
17
+ * Fix list_consumer_groups() to query all brokers (jeffwidman #1635 )
18
+ * Stop using broker-errors for client-side problems (jeffwidman #1639 )
19
+ * Fix send to controller (jeffwidman #1640 )
20
+ * Add group coordinator lookup (jeffwidman #1641 )
21
+ * Fix describe_groups (jeffwidman #1642 )
22
+ * Add list_consumer_group_offsets() (jeffwidman #1643 )
23
+ * Remove support for api versions as strings from KafkaAdminClient (jeffwidman #1644 )
24
+ * Set a clear default value for ` validate_only ` /` include_synonyms ` (jeffwidman #1645 )
25
+ * Bugfix: Always set this_groups_coordinator_id (jeffwidman #1650 )
13
26
14
27
Consumer
15
28
* Fix linter warning on import of ConsumerRebalanceListener (ben-harack #1591 )
16
29
* Remove ConsumerTimeout (emord #1587 )
17
30
* Return future from commit_offsets_async() (ekimekim #1560 )
18
31
19
32
Core / Protocol
33
+ * Add protocol structs for {Describe,Create,Delete} Acls (ulrikjohansson #1646 /partial)
20
34
* Pre-compile pack/unpack function calls (billyevans / jeffwidman #1619 )
21
35
* Don't use ` kafka.common ` internally (jeffwidman #1509 )
36
+ * Be explicit with tuples for %s formatting (jeffwidman #1634 )
22
37
23
38
Documentation
24
39
* Document connections_max_idle_ms (jeffwidman #1531 )
25
40
* Fix sphinx url (jeffwidman #1610 )
26
41
* Update remote urls: snappy, https, etc (jeffwidman #1603 )
27
42
* Minor cleanup of testing doc (jeffwidman #1613 )
43
+ * Various docstring / pep8 / code hygiene cleanups (jeffwidman #1647 )
28
44
29
45
Test Infrastructure
30
46
* Stop pinning ` pylint ` (jeffwidman #1611 )
@@ -33,6 +49,8 @@ Test Infrastructure
33
49
* Cleanup fixture imports (jeffwidman #1616 )
34
50
* Fix typo in test file name (jeffwidman)
35
51
* Remove unused ivy_root variable (jeffwidman)
52
+ * Add test fixtures for kafka versions 1.0.2 -> 2.0.1 (dpkp)
53
+ * Bump travis test for 1.x brokers to 1.1.1 (dpkp)
36
54
37
55
Logging / Error Messages
38
56
* raising logging level on messages signalling data loss (sibiryakov #1553 )
0 commit comments