github confluentinc/confluent-kafka-python v1.6.1

latest releases: v2.6.0.post1.dev2, v2.6.0.post1.dev1, v2.6.0...
3 years ago

v1.6.1

v1.6.1 is a feature release:

  • KIP-429 - Incremental consumer rebalancing support.
  • OAUTHBEARER support.

Fixes

  • Add return_record_name=True to AvroDeserializer (@slominskir, #1028)
  • Fix deprecated schema.Parse call (@casperlehmann, #1006).
  • Make reader schema optional in AvroDeserializer (@97nitt, #1000).
  • Add **kwargs to legacy AvroProducer and AvroConsumer constructors to
    support all Consumer and Producer base class constructor arguments, such
    as logger (@venthur, #699).
  • Add bool for permanent schema delete (@slominskir, #1029).
  • The avro package is no longer required for Schema-Registry support (@jaysonsantos, #950).
  • Only write to schema cache once, improving performance (@fimmtiu, #724).
  • Improve Schema-Registry error reporting (@jacopofar, #673).
  • producer.flush() could return a non-zero value without hitting the specified timeout.

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

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

NewReleases is sending notifications on new releases.