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
aslogger
(@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.