github confluentinc/confluent-kafka-python v1.3.0

latest releases: v2.4.0, v2.4.0rc3, v2.3.0rc5.dev1...
4 years ago

Confluent's Python client for Apache Kafka

confluent-kafka-python is based on librdkafka v1.3.0, see the librdkafka v1.3.0 release notes for a complete list of changes, enhancements, fixes and upgrade considerations.

This is a feature release adding support for KIP-392 Fetch from follower, allowing a consumer to fetch messages from the closest replica to increase throughput and reduce cost.

Features

  • KIP-392 - Fetch messages from closest replica / follower (by @mhowlett)
  • Python 3.8 binary wheel support for OSX and Linux. Windows Python 3.8 binary wheels are not currently available.

Enhancements

  • New example using python3 and asyncio (by @mhowlett)
  • Add warnings for inconsistent security configuration.
  • Optimizations to hdr histogram (stats) rollover.
  • Print compression type per message-set when debug=msg
  • Various doc fixes, updates and enhancements (@edenhill , @mhowlett)

Fixes

  • Fix crash when new topic is not created. (@mostafa Razavi,#725)
  • Fix stringer/repr for SerializerError class(@ferozed#675)
  • Fix consumer_lag in stats when consuming from broker versions <0.11.0.0 (regression in librdkafka v1.2.0).
  • Properly handle new Kafka-framed SASL GSSAPI frame semantics on Windows (#2542). 
This bug was introduced in v1.2.0 and broke GSSAPI authentication on Windows.
  • Fix msgq (re)insertion code to avoid O(N^2) insert sort operations on retry (#2508).
 The msgq insert code now properly handles interleaved and overlapping message range inserts, which may occur during Producer retries for
 high-throughput applications.
  • Fix producer insert msgq regression in v1.2.1 (#2450).
  • Upgrade builtin lz4 to 1.9.2 (CVE-2019-17543, #2598).
  • Don't trigger error when broker hostname changes (#2591).
  • Less strict message.max.bytes check for individual messages (#993).
  • Don't call timespec_get() on OSX (since it was removed in recent XCode) by @maparent .
  • LZ4 is available from ProduceRequest 0, not 3 (fixes assert in #2480).
  • Address 12 code issues identified by Coverity static code analysis.

Don't miss a new confluent-kafka-python release

NewReleases is sending notifications on new releases.