From 5a6efc2dc1e739437bc0d86804454d615004b499 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 17 Apr 2024 14:02:00 -0700 Subject: [PATCH 1/9] Update CHANGES.md with latest --- CHANGES.md | 50 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 50 insertions(+) diff --git a/CHANGES.md b/CHANGES.md index 097c55db6..7a08e4246 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -1,3 +1,53 @@ +# Unreleased + +TODO / Uncategorized Changes +* 364397c [FIX] suitablt for the high vresion python. (#2394) +* 38e8d04 Update conn.py to catch OSError in case of failed import (#2407) +* 4861bee Uses assert_called_with instead of called_with (#2375) +* d894e9a build: update vendored six from 1.11.0 to 1.16.0 (#2398) +* a33fcf4 Update setup.py to install zstandard instead of python-zstandard (#2387) +* d920108 use isinstance in builtin crc32 (#2329) +* 7ac6c6e Allow disabling thread wakeup in send_request_to_node (#2335) +* 9feeb79 Core Protocol: Add support for flexible versions (#2151) +* c48817e Support configuration of custom kafka client for Admin/Consumer/Producer (#2144) +* 53dc740 Hotfix: TypeError: object of type 'dict_itemiterator' has no len() (#2167) +* c605e0c Add the optional compression libs to extras_require (#2123) +* 6c87155 KafkaConsumer: Exit poll if consumer is closed (#2152) +* 12325c0 Only try to update sensors fetch lag if the unpacked list contains elements (#2158) +* b090b21 Cover sticky assignor's metadata method with tests (#2161) +* 83b7b27 Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154) +* f984984 Update fixtures.py to use "127.0.0.1" for local ports (#2384) + + +CI/CD +* b68f61d Bump actions/setup-java from 3 to 4 (#2417) +* e9dfaf9 Bump actions/setup-python from 4 to 5 (#2418) +* 43822d0 Bump github/codeql-action from 2 to 3 (#2419) +* 0864817 Update python-package.yml to publish to PyPi for every release (#2381) +* a1d268a Update PYTHON_LATEST in python-package.yml to 3.12 +* 0362b87 Update python-package.yml to expect 3.12 tests to pass and extend experimental tests (#2406) +* 779a23c Bump actions/checkout from 3 to 4 (#2392) +* f8a7e9b Transition CI/CD to GitHub Workflows (#2378) + +Compatibility +* 7e87a01 Add py312 to tox.ini (#2382) +* 57d8338 Enable testing for Python 3.12 (#2379) +* 0dbf746 Update setup.py to indicate 3.12 support +* 8b8a48b Add Kafka 2.6.0 to tests and protocol compatibility matrix (#2162) +* eb070d6 Add kafka-2.5 to compatibility + +Documentation +* a6d0579 Update README.rst +* b7a9be6 Update usage.rst (#2308) +* 46473ba docs: Fix a few typos (#2319) +* 94901bb Update usage.rst (#2334) +* 4d59805 Fix the link to the compatibility page (#2295) +* f0a57a6 Fix producerconfigs documentation link (#2226) +* f19e423 Fix typo: veriication -> verification (#2207) +* 6521c1d fix typo in documentation (#2178) +* b0c5930 Cleanup install instructions for optional libs (#2139) + + # 2.0.2 (Sep 29, 2020) Consumer From e9c8768b911747c34a74c9f840b8e90f228ecd95 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 6 Feb 2025 08:13:03 -0800 Subject: [PATCH 2/9] categories --- CHANGES.md | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/CHANGES.md b/CHANGES.md index 7a08e4246..330bcce8f 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -1,12 +1,6 @@ # Unreleased TODO / Uncategorized Changes -* 364397c [FIX] suitablt for the high vresion python. (#2394) -* 38e8d04 Update conn.py to catch OSError in case of failed import (#2407) -* 4861bee Uses assert_called_with instead of called_with (#2375) -* d894e9a build: update vendored six from 1.11.0 to 1.16.0 (#2398) -* a33fcf4 Update setup.py to install zstandard instead of python-zstandard (#2387) -* d920108 use isinstance in builtin crc32 (#2329) * 7ac6c6e Allow disabling thread wakeup in send_request_to_node (#2335) * 9feeb79 Core Protocol: Add support for flexible versions (#2151) * c48817e Support configuration of custom kafka client for Admin/Consumer/Producer (#2144) @@ -35,6 +29,9 @@ Compatibility * 0dbf746 Update setup.py to indicate 3.12 support * 8b8a48b Add Kafka 2.6.0 to tests and protocol compatibility matrix (#2162) * eb070d6 Add kafka-2.5 to compatibility +* 364397c Try collections.abc imports in vendored selectors34 (#2394) +* 38e8d04 Catch OSError when checking for gssapi import for windows compatibility (#2407) +* d894e9a update vendored six to 1.16.0 (#2398) Documentation * a6d0579 Update README.rst @@ -47,6 +44,12 @@ Documentation * 6521c1d fix typo in documentation (#2178) * b0c5930 Cleanup install instructions for optional libs (#2139) +Fixes +* a33fcf4 Fix zstandard (optional) install in setup.py (#2387) +* d920108 Use isinstance in builtin crc32 (#2329) + +Testing +* 4861bee Uses assert_called_with in client_async tests (#2375) # 2.0.2 (Sep 29, 2020) From 5be15094b9630913834bf31f8f5b9e379d8943c4 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 10 Feb 2025 10:16:39 -0800 Subject: [PATCH 3/9] whitespace --- docs/changelog.rst | 6 +++--- docs/usage.rst | 16 ++++++++-------- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/docs/changelog.rst b/docs/changelog.rst index 446b29021..34d9c8f09 100644 --- a/docs/changelog.rst +++ b/docs/changelog.rst @@ -1243,7 +1243,7 @@ Consumers * Improve FailedPayloadsError handling in KafkaConsumer (dpkp PR 398) * KafkaConsumer: avoid raising KeyError in task_done (dpkp PR 389) * MultiProcessConsumer -- support configured partitions list (dpkp PR 380) -* Fix SimpleConsumer leadership change handling (dpkp PR 393) +* Fix SimpleConsumer leadership change handling (dpkp PR 393) * Fix SimpleConsumer connection error handling (reAsOn2010 PR 392) * Improve Consumer handling of 'falsy' partition values (wting PR 342) * Fix _offsets call error in KafkaConsumer (hellais PR 376) @@ -1348,7 +1348,7 @@ Internals * Add test timers via nose-timer plugin; list 10 slowest timings by default (dpkp) * Move fetching last known offset logic to a stand alone function (zever - PR 177) * Improve KafkaConnection and add more tests (dpkp - PR 196) -* Raise TypeError if necessary when encoding strings (mdaniel - PR 204) +* Raise TypeError if necessary when encoding strings (mdaniel - PR 204) * Use Travis-CI to publish tagged releases to pypi (tkuhlman / mumrah) * Use official binary tarballs for integration tests and parallelize travis tests (dpkp - PR 193) * Improve new-topic creation handling (wizzat - PR 174) @@ -1362,7 +1362,7 @@ Internals * Fix connection error timeout and improve tests (wizzat - PR 158) * SimpleProducer randomization of initial round robin ordering (alexcb - PR 139) * Fix connection timeout in KafkaClient and KafkaConnection (maciejkula - PR 161) -* Fix seek + commit behavior (wizzat - PR 148) +* Fix seek + commit behavior (wizzat - PR 148) 0.9.0 (Mar 21, 2014) diff --git a/docs/usage.rst b/docs/usage.rst index 047bbad77..c001ec049 100644 --- a/docs/usage.rst +++ b/docs/usage.rst @@ -28,7 +28,7 @@ KafkaConsumer # consume json messages KafkaConsumer(value_deserializer=lambda m: json.loads(m.decode('ascii'))) - # consume msgpack + # consume msgpack KafkaConsumer(value_deserializer=msgpack.unpackb) # StopIteration if no message after 1sec @@ -104,7 +104,7 @@ KafkaProducer log.error('I am an errback', exc_info=excp) # handle exception - # produce asynchronously with callbacks + # produce asynchronously with callbacks producer.send('my-topic', b'raw_bytes').add_callback(on_send_success).add_errback(on_send_error) # block until all async messages are sent @@ -112,8 +112,8 @@ KafkaProducer # configure multiple retries producer = KafkaProducer(retries=5) - - + + ClusterMetadata ============= .. code:: python @@ -131,7 +131,7 @@ ClusterMetadata # get all partitions of a topic print(clusterMetadata.partitions_for_topic("topic")) - # list topics + # list topics print(clusterMetadata.topics()) @@ -140,9 +140,9 @@ KafkaAdminClient .. code:: python from kafka import KafkaAdminClient from kafka.admin import NewTopic - + admin = KafkaAdminClient(bootstrap_servers=['broker1:1234']) - + # create a new topic topics_list = [] topics_list.append(NewTopic(name="testtopic", num_partitions=1, replication_factor=1)) @@ -160,4 +160,4 @@ KafkaAdminClient # get consumer group offset print(admin.list_consumer_group_offsets('cft-plt-qa.connect')) - + From 7708c84bf393a4337997daef4db01608f637a87c Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 10 Feb 2025 10:35:19 -0800 Subject: [PATCH 4/9] Updates --- CHANGES.md | 77 +++++++++++++++++++++++------------------------------- 1 file changed, 33 insertions(+), 44 deletions(-) diff --git a/CHANGES.md b/CHANGES.md index 330bcce8f..285eeea35 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -1,55 +1,44 @@ -# Unreleased - -TODO / Uncategorized Changes -* 7ac6c6e Allow disabling thread wakeup in send_request_to_node (#2335) -* 9feeb79 Core Protocol: Add support for flexible versions (#2151) -* c48817e Support configuration of custom kafka client for Admin/Consumer/Producer (#2144) -* 53dc740 Hotfix: TypeError: object of type 'dict_itemiterator' has no len() (#2167) -* c605e0c Add the optional compression libs to extras_require (#2123) -* 6c87155 KafkaConsumer: Exit poll if consumer is closed (#2152) -* 12325c0 Only try to update sensors fetch lag if the unpacked list contains elements (#2158) -* b090b21 Cover sticky assignor's metadata method with tests (#2161) -* 83b7b27 Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154) -* f984984 Update fixtures.py to use "127.0.0.1" for local ports (#2384) - - -CI/CD -* b68f61d Bump actions/setup-java from 3 to 4 (#2417) -* e9dfaf9 Bump actions/setup-python from 4 to 5 (#2418) -* 43822d0 Bump github/codeql-action from 2 to 3 (#2419) -* 0864817 Update python-package.yml to publish to PyPi for every release (#2381) -* a1d268a Update PYTHON_LATEST in python-package.yml to 3.12 -* 0362b87 Update python-package.yml to expect 3.12 tests to pass and extend experimental tests (#2406) -* 779a23c Bump actions/checkout from 3 to 4 (#2392) -* f8a7e9b Transition CI/CD to GitHub Workflows (#2378) +# 2.0.3 (Feb 10, 2025) + +Improvements +* Add optional compression libs to extras_require (#2123, #2387) +* KafkaConsumer: Exit poll if consumer is closed (#2152) +* Support configuration of custom kafka client for Admin/Consumer/Producer (#2144) +* Core Protocol: Add support for flexible versions (#2151) +* (Internal) Allow disabling thread wakeup in _send_request_to_node (#2335) Compatibility -* 7e87a01 Add py312 to tox.ini (#2382) -* 57d8338 Enable testing for Python 3.12 (#2379) -* 0dbf746 Update setup.py to indicate 3.12 support -* 8b8a48b Add Kafka 2.6.0 to tests and protocol compatibility matrix (#2162) -* eb070d6 Add kafka-2.5 to compatibility -* 364397c Try collections.abc imports in vendored selectors34 (#2394) -* 38e8d04 Catch OSError when checking for gssapi import for windows compatibility (#2407) -* d894e9a update vendored six to 1.16.0 (#2398) +* Support for python 3.12 (#2379, #2382) +* Kafka 2.5 / 2.6 (#2162) +* Try collections.abc imports in vendored selectors34 (#2394) +* Catch OSError when checking for gssapi import for windows compatibility (#2407) +* Update vendored six to 1.16.0 (#2398) Documentation -* a6d0579 Update README.rst -* b7a9be6 Update usage.rst (#2308) -* 46473ba docs: Fix a few typos (#2319) -* 94901bb Update usage.rst (#2334) -* 4d59805 Fix the link to the compatibility page (#2295) -* f0a57a6 Fix producerconfigs documentation link (#2226) -* f19e423 Fix typo: veriication -> verification (#2207) -* 6521c1d fix typo in documentation (#2178) -* b0c5930 Cleanup install instructions for optional libs (#2139) +* Update usage.rst (#2308, #2334) +* Fix typos (#2319, #2207, #2178) +* Fix links to the compatibility page (#2295, #2226) +* Cleanup install instructions for optional libs (#2139) +* Update license_file to license_files (#2462) +* Update some RST documentation syntax (#2463) Fixes -* a33fcf4 Fix zstandard (optional) install in setup.py (#2387) -* d920108 Use isinstance in builtin crc32 (#2329) +* Use isinstance in builtin crc32 (#2329) +* Use six.viewitems instead of six.iteritems to avoid encoding problems in StickyPartitionAssignor (#2154) +* Fix array encoding TypeError: object of type 'dict_itemiterator' has no len() (#2167) +* Only try to update sensors fetch lag if the unpacked list contains elements (#2158) +* Avoid logging errors during test fixture cleanup (#2458) +* Release coordinator lock before calling maybe_leave_group (#2460) +* Dont raise RuntimeError for dead process in SpawnedService.wait_for() (#2461) +* Casts the size of a MemoryRecordsBuilder object (#2438) +* Fix DescribeConfigsResponse_v1 config_source (#2464) Testing -* 4861bee Uses assert_called_with in client_async tests (#2375) +* Transition CI/CD to GitHub Workflows (#2378, #2392, #2381, #2406, #2419, #2418, #2417, #2456) +* Refactor Makefile (#2457) +* Uses assert_called_with in client_async tests (#2375) +* Cover sticky assignor's metadata method with tests (#2161) +* Update fixtures.py to check "127.0.0.1" for auto port assignment (#2384) # 2.0.2 (Sep 29, 2020) From 0ba9e5e7683d3acd86d1252f0bd40cf507d2c90c Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 10 Feb 2025 11:21:35 -0800 Subject: [PATCH 5/9] update + changelog.rst --- CHANGES.md | 2 ++ docs/changelog.rst | 51 ++++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 53 insertions(+) diff --git a/CHANGES.md b/CHANGES.md index 285eeea35..48cd8f365 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -6,6 +6,7 @@ Improvements * Support configuration of custom kafka client for Admin/Consumer/Producer (#2144) * Core Protocol: Add support for flexible versions (#2151) * (Internal) Allow disabling thread wakeup in _send_request_to_node (#2335) +* Change loglevel of cancelled errors to info (#2467) Compatibility * Support for python 3.12 (#2379, #2382) @@ -32,6 +33,7 @@ Fixes * Dont raise RuntimeError for dead process in SpawnedService.wait_for() (#2461) * Casts the size of a MemoryRecordsBuilder object (#2438) * Fix DescribeConfigsResponse_v1 config_source (#2464) +* Fix base class of DescribeClientQuotasResponse_v0 (#2465) Testing * Transition CI/CD to GitHub Workflows (#2378, #2392, #2381, #2406, #2419, #2418, #2417, #2456) diff --git a/docs/changelog.rst b/docs/changelog.rst index 34d9c8f09..bdac284e5 100644 --- a/docs/changelog.rst +++ b/docs/changelog.rst @@ -2,6 +2,57 @@ Changelog ========= +2.0.3 (Feb 10, 2025) +#################### + +Improvements +------------ +* Add optional compression libs to extras_require (#2123, #2387) +* KafkaConsumer: Exit poll if consumer is closed (#2152) +* Support configuration of custom kafka client for Admin/Consumer/Producer (#2144) +* Core Protocol: Add support for flexible versions (#2151) +* (Internal) Allow disabling thread wakeup in _send_request_to_node (#2335) +* Change loglevel of cancelled errors to info (#2467) + +Compatibility +------------- +* Support for python 3.12 (#2379, #2382) +* Kafka 2.5 / 2.6 (#2162) +* Try collections.abc imports in vendored selectors34 (#2394) +* Catch OSError when checking for gssapi import for windows compatibility (#2407) +* Update vendored six to 1.16.0 (#2398) + +Documentation +------------- +* Update usage.rst (#2308, #2334) +* Fix typos (#2319, #2207, #2178) +* Fix links to the compatibility page (#2295, #2226) +* Cleanup install instructions for optional libs (#2139) +* Update license_file to license_files (#2462) +* Update some RST documentation syntax (#2463) + +Fixes +----- +* Use isinstance in builtin crc32 (#2329) +* Use six.viewitems instead of six.iteritems to avoid encoding problems in StickyPartitionAssignor (#2154) +* Fix array encoding TypeError: object of type 'dict_itemiterator' has no len() (#2167) +* Only try to update sensors fetch lag if the unpacked list contains elements (#2158) +* Avoid logging errors during test fixture cleanup (#2458) +* Release coordinator lock before calling maybe_leave_group (#2460) +* Dont raise RuntimeError for dead process in SpawnedService.wait_for() (#2461) +* Casts the size of a MemoryRecordsBuilder object (#2438) +* Fix DescribeConfigsResponse_v1 config_source (#2464) +* Fix base class of DescribeClientQuotasResponse_v0 (#2465) + +Testing +------- +* Transition CI/CD to GitHub Workflows (#2378, #2392, #2381, #2406, #2419, #2418, #2417, #2456) +* Refactor Makefile (#2457) +* Uses assert_called_with in client_async tests (#2375) +* Cover sticky assignor's metadata method with tests (#2161) +* Update fixtures.py to check "127.0.0.1" for auto port assignment (#2384) + + 2.0.2 (Sep 29, 2020) #################### From c09f8057f57cee180f1aa0fb319f7f891fdcc15b Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 12 Feb 2025 11:30:39 -0800 Subject: [PATCH 6/9] socketpair changes --- CHANGES.md | 1 + docs/changelog.rst | 1 + 2 files changed, 2 insertions(+) diff --git a/CHANGES.md b/CHANGES.md index 48cd8f365..d9bc3b450 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -34,6 +34,7 @@ Fixes * Casts the size of a MemoryRecordsBuilder object (#2438) * Fix DescribeConfigsResponse_v1 config_source (#2464) * Fix base class of DescribeClientQuotasResponse_v0 (#2465) +* Update socketpair w/ CVE-2024-3219 fix (#2468) Testing * Transition CI/CD to GitHub Workflows (#2378, #2392, #2381, #2406, #2419, #2418, #2417, #2456) diff --git a/docs/changelog.rst b/docs/changelog.rst index bdac284e5..c3c96aa67 100644 --- a/docs/changelog.rst +++ b/docs/changelog.rst @@ -43,6 +43,7 @@ Fixes * Casts the size of a MemoryRecordsBuilder object (#2438) * Fix DescribeConfigsResponse_v1 config_source (#2464) * Fix base class of DescribeClientQuotasResponse_v0 (#2465) +* Update socketpair w/ CVE-2024-3219 fix (#2468) Testing ------- From 28e1c90dd19e95c11a0930fe987ab5711d0486f3 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 12 Feb 2025 11:32:43 -0800 Subject: [PATCH 7/9] grammar nits --- CHANGES.md | 6 +++--- docs/changelog.rst | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/CHANGES.md b/CHANGES.md index d9bc3b450..dba037528 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -1,4 +1,4 @@ -# 2.0.3 (Feb 10, 2025) +# 2.0.3 (Feb 12, 2025) Improvements * Add optional compression libs to extras_require (#2123, #2387) @@ -31,7 +31,7 @@ Fixes * Avoid logging errors during test fixture cleanup (#2458) * Release coordinator lock before calling maybe_leave_group (#2460) * Dont raise RuntimeError for dead process in SpawnedService.wait_for() (#2461) -* Casts the size of a MemoryRecordsBuilder object (#2438) +* Cast the size of a MemoryRecordsBuilder object (#2438) * Fix DescribeConfigsResponse_v1 config_source (#2464) * Fix base class of DescribeClientQuotasResponse_v0 (#2465) * Update socketpair w/ CVE-2024-3219 fix (#2468) @@ -39,7 +39,7 @@ Fixes Testing * Transition CI/CD to GitHub Workflows (#2378, #2392, #2381, #2406, #2419, #2418, #2417, #2456) * Refactor Makefile (#2457) -* Uses assert_called_with in client_async tests (#2375) +* Use assert_called_with in client_async tests (#2375) * Cover sticky assignor's metadata method with tests (#2161) * Update fixtures.py to check "127.0.0.1" for auto port assignment (#2384) diff --git a/docs/changelog.rst b/docs/changelog.rst index c3c96aa67..8a96ca75b 100644 --- a/docs/changelog.rst +++ b/docs/changelog.rst @@ -2,7 +2,7 @@ Changelog ========= -2.0.3 (Feb 10, 2025) +2.0.3 (Feb 12, 2025) #################### Improvements @@ -40,7 +40,7 @@ Fixes * Avoid logging errors during test fixture cleanup (#2458) * Release coordinator lock before calling maybe_leave_group (#2460) * Dont raise RuntimeError for dead process in SpawnedService.wait_for() (#2461) -* Casts the size of a MemoryRecordsBuilder object (#2438) +* Cast the size of a MemoryRecordsBuilder object (#2438) * Fix DescribeConfigsResponse_v1 config_source (#2464) * Fix base class of DescribeClientQuotasResponse_v0 (#2465) * Update socketpair w/ CVE-2024-3219 fix (#2468) @@ -49,7 +49,7 @@ Testing ------- * Transition CI/CD to GitHub Workflows (#2378, #2392, #2381, #2406, #2419, #2418, #2417, #2456) * Refactor Makefile (#2457) -* Uses assert_called_with in client_async tests (#2375) +* Use assert_called_with in client_async tests (#2375) * Cover sticky assignor's metadata method with tests (#2161) * Update fixtures.py to check "127.0.0.1" for auto port assignment (#2384) From 7d126a5fb9a757adb3952160babded89842593a8 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 12 Feb 2025 12:49:32 -0800 Subject: [PATCH 8/9] more changes --- CHANGES.md | 7 +++++++ docs/changelog.rst | 7 +++++++ 2 files changed, 14 insertions(+) diff --git a/CHANGES.md b/CHANGES.md index dba037528..27ee997ac 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -7,6 +7,9 @@ Improvements * Core Protocol: Add support for flexible versions (#2151) * (Internal) Allow disabling thread wakeup in _send_request_to_node (#2335) * Change loglevel of cancelled errors to info (#2467) +* Strip trailing dot off hostname for SSL validation. (#2472) +* Log connection close(error) at ERROR level (#2473) +* Support DescribeLogDirs admin api (#2475) Compatibility * Support for python 3.12 (#2379, #2382) @@ -22,6 +25,7 @@ Documentation * Cleanup install instructions for optional libs (#2139) * Update license_file to license_files (#2462) * Update some RST documentation syntax (#2463) +* Add .readthedocs.yaml; update copyright date (#2474) Fixes * Use isinstance in builtin crc32 (#2329) @@ -42,6 +46,9 @@ Testing * Use assert_called_with in client_async tests (#2375) * Cover sticky assignor's metadata method with tests (#2161) * Update fixtures.py to check "127.0.0.1" for auto port assignment (#2384) +* Use -Djava.security.manager=allow for Java 23 sasl tests (#2469) +* Test with Java 23 (#2470) +* Update kafka properties template; disable group rebalance delay (#2471) # 2.0.2 (Sep 29, 2020) diff --git a/docs/changelog.rst b/docs/changelog.rst index 8a96ca75b..b8f51e337 100644 --- a/docs/changelog.rst +++ b/docs/changelog.rst @@ -13,6 +13,9 @@ Improvements * Core Protocol: Add support for flexible versions (#2151) * (Internal) Allow disabling thread wakeup in _send_request_to_node (#2335) * Change loglevel of cancelled errors to info (#2467) +* Strip trailing dot off hostname for SSL validation. (#2472) +* Log connection close(error) at ERROR level (#2473) +* Support DescribeLogDirs admin api (#2475) Compatibility ------------- @@ -30,6 +33,7 @@ Documentation * Cleanup install instructions for optional libs (#2139) * Update license_file to license_files (#2462) * Update some RST documentation syntax (#2463) +* Add .readthedocs.yaml; update copyright date (#2474) Fixes ----- @@ -52,6 +56,9 @@ Testing * Use assert_called_with in client_async tests (#2375) * Cover sticky assignor's metadata method with tests (#2161) * Update fixtures.py to check "127.0.0.1" for auto port assignment (#2384) +* Use -Djava.security.manager=allow for Java 23 sasl tests (#2469) +* Test with Java 23 (#2470) +* Update kafka properties template; disable group rebalance delay (#2471) 2.0.2 (Sep 29, 2020) From 313507cf734f20794c7ec0be1916d51065e60ee7 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 12 Feb 2025 14:27:37 -0800 Subject: [PATCH 9/9] Release 2.0.3 --- kafka/version.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/version.py b/kafka/version.py index 06306bd1f..e7c12d285 100644 --- a/kafka/version.py +++ b/kafka/version.py @@ -1 +1 @@ -__version__ = '2.0.3-dev' +__version__ = '2.0.3'