diff options
author | Dana Powers <dana.powers@gmail.com> | 2019-03-14 18:24:51 -0700 |
---|---|---|
committer | Dana Powers <dana.powers@gmail.com> | 2019-03-14 18:25:09 -0700 |
commit | 225741965ef1cd791bd2722f120697c55ba2dccc (patch) | |
tree | 29594b673152f907ac7f494d2f6c57ba671fe7b2 | |
parent | 965d21b21387e69c53f583fd76cdcec2a4d0f944 (diff) | |
download | kafka-python-225741965ef1cd791bd2722f120697c55ba2dccc.tar.gz |
Release 1.4.51.4.5
-rw-r--r-- | CHANGES.md | 50 | ||||
-rw-r--r-- | docs/changelog.rst | 50 | ||||
-rw-r--r-- | docs/compatibility.rst | 2 | ||||
-rw-r--r-- | kafka/version.py | 2 |
4 files changed, 102 insertions, 2 deletions
@@ -1,3 +1,53 @@ +# 1.4.5 (Mar 14, 2019) + +This release is primarily focused on addressing lock contention +and other coordination issues between the KafkaConsumer and the +background heartbeat thread that was introduced in the 1.4 release. + +Consumer +* connections_max_idle_ms must be larger than request_timeout_ms (jeffwidman / PR #1688) +* Avoid race condition during close() / join heartbeat thread (dpkp / PR #1735) +* Use last offset from fetch v4 if available to avoid getting stuck in compacted topic (keithks / PR #1724) +* Synchronize puts to KafkaConsumer protocol buffer during async sends (dpkp / PR #1733) +* Improve KafkaConsumer join group / only enable Heartbeat Thread during stable group (dpkp / PR #1695) +* Remove unused `skip_double_compressed_messages` (jeffwidman / PR #1677) +* Fix commit_offsets_async() callback (Faqa / PR #1712) + +Client +* Retry bootstrapping after backoff when necessary (dpkp / PR #1736) +* Recheck connecting nodes sooner when refreshing metadata (dpkp / PR #1737) +* Avoid probing broker versions twice on newer brokers (dpkp / PR #1738) +* Move all network connections and writes to KafkaClient.poll() (dpkp / PR #1729) +* Do not require client lock for read-only operations (dpkp / PR #1730) +* Timeout all unconnected conns (incl SSL) after request_timeout_ms (dpkp / PR #1696) + +Admin Client +* Fix AttributeError in response topic error codes checking (jeffwidman) +* Fix response error checking in KafkaAdminClient send_to_controller (jeffwidman) +* Fix NotControllerError check (jeffwidman) + +Core/Protocol +* Fix default protocol parser version / 0.8.2 version probe (dpkp / PR #1740) +* Make NotEnoughReplicasError/NotEnoughReplicasAfterAppendError retriable (le-linh / PR #1722) + +Bugfixes +* Use copy() in metrics() to avoid thread safety issues (emeric254 / PR #1682) + +Test Infrastructure +* Mock dns lookups in test_conn (dpkp / PR #1739) +* Use test.fixtures.version not test.conftest.version to avoid warnings (dpkp / PR #1731) +* Fix test_legacy_correct_metadata_response on x86 arch (stanislavlevin / PR #1718) +* Travis CI: 'sudo' tag is now deprecated in Travis (cclauss / PR #1698) +* Use Popen.communicate() instead of Popen.wait() (Baisang / PR #1689) + +Compatibility +* Catch thrown OSError by python 3.7 when creating a connection (danjo133 / PR #1694) +* Update travis test coverage: 2.7, 3.4, 3.7, pypy2.7 (jeffwidman, dpkp / PR #1614) +* Drop dependency on sphinxcontrib-napoleon (stanislavlevin / PR #1715) +* Remove unused import from kafka/producer/record_accumulator.py (jeffwidman / PR #1705) +* Fix SSL connection testing in Python 3.7 (seanthegeek, silentben / PR #1669) + + # 1.4.4 (Nov 20, 2018) Bugfixes diff --git a/docs/changelog.rst b/docs/changelog.rst index ee84be1..1852f9b 100644 --- a/docs/changelog.rst +++ b/docs/changelog.rst @@ -2,6 +2,56 @@ Changelog ========= +1.4.5 (Mar 14, 2019) +#################### + +This release is primarily focused on addressing lock contention +and other coordination issues between the KafkaConsumer and the +background heartbeat thread that was introduced in the 1.4 release. + +Consumer +-------- +* connections_max_idle_ms must be larger than request_timeout_ms (jeffwidman / PR #1688) +* Avoid race condition during close() / join heartbeat thread (dpkp / PR #1735) +* Use last offset from fetch v4 if available to avoid getting stuck in compacted topic (keithks / PR #1724) +* Synchronize puts to KafkaConsumer protocol buffer during async sends (dpkp / PR #1733) +* Improve KafkaConsumer join group / only enable Heartbeat Thread during stable group (dpkp / PR #1695) +* Remove unused `skip_double_compressed_messages` (jeffwidman / PR #1677) +* Fix commit_offsets_async() callback (Faqa / PR #1712) + +Client +------ +* Retry bootstrapping after backoff when necessary (dpkp / PR #1736) +* Recheck connecting nodes sooner when refreshing metadata (dpkp / PR #1737) +* Avoid probing broker versions twice on newer brokers (dpkp / PR #1738) +* Move all network connections and writes to KafkaClient.poll() (dpkp / PR #1729) +* Do not require client lock for read-only operations (dpkp / PR #1730) +* Timeout all unconnected conns (incl SSL) after request_timeout_ms (dpkp / PR #1696) + +Admin Client +------------ +* Fix AttributeError in response topic error codes checking (jeffwidman) +* Fix response error checking in KafkaAdminClient send_to_controller (jeffwidman) +* Fix NotControllerError check (jeffwidman) + +Core/Protocol +------------- +* Fix default protocol parser version / 0.8.2 version probe (dpkp / PR #1740) +* Make NotEnoughReplicasError/NotEnoughReplicasAfterAppendError retriable (le-linh / PR #1722) + +Bugfixes +-------- +* Use copy() in metrics() to avoid thread safety issues (emeric254 / PR #1682) + +Test Infrastructure +------------------- +* Mock dns lookups in test_conn (dpkp / PR #1739) +* Use test.fixtures.version not test.conftest.version to avoid warnings (dpkp / PR #1731) +* Fix test_legacy_correct_metadata_response on x86 arch (stanislavlevin / PR #1718) +* Travis CI: 'sudo' tag is now deprecated in Travis (cclauss / PR #1698) +* Use Popen.communicate() instead of Popen.wait() (Baisang / PR #1689) + + 1.4.4 (Nov 20, 2018) ########## diff --git a/docs/compatibility.rst b/docs/compatibility.rst index ce222ee..fc9e7cc 100644 --- a/docs/compatibility.rst +++ b/docs/compatibility.rst @@ -12,6 +12,6 @@ through 0.8.0 . kafka-python is not compatible with the 0.8.2-beta release. Because the kafka server protocol is backwards compatible, kafka-python is expected to work with newer broker releases as well (2.0+). -kafka-python is tested on python 2.7, 3.4, 3.5, 3.6, 3.7, and pypy. +kafka-python is tested on python 2.7, 3.4, 3.7, and pypy2.7. Builds and tests via Travis-CI. See https://travis-ci.org/dpkp/kafka-python diff --git a/kafka/version.py b/kafka/version.py index 200a41d..5e235ea 100644 --- a/kafka/version.py +++ b/kafka/version.py @@ -1 +1 @@ -__version__ = '1.4.5.dev' +__version__ = '1.4.5' |