Skip to content

2.0.3

Latest
Latest
Compare
Choose a tag to compare
@dpkp dpkp released this 12 Feb 23:04
· 8 commits to master since this release
2.0.3
840c0d6
This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Verified
Learn about vigilant mode.

2.0.3 (Feb 12, 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)
  • 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)
  • 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)
  • Add .readthedocs.yaml; update copyright date (#2474)

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)
  • 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)

Testing

  • Transition CI/CD to GitHub Workflows (#2378, #2392, #2381, #2406, #2419, #2418, #2417, #2456)
  • Refactor Makefile (#2457)
  • 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)
Assets 2
Loading