v2.1.0
This is a feature release.
- Added Consumer
SeekPartitions()
method to seek multiple partitions at once and deprecatedSeek()
(#940). - KIP-320: add offset leader epoch to the TopicPartition and Message structs (#968).
- The minimum version of Go supported has been changed from 1.14 to 1.16 (#973).
- Add validation on the Producer, the Consumer and the AdminClient to prevent panic when they are used after close (#901).
- Fix bug causing schema-registry URL with existing path to not be parsed correctly (#950).
- Support for Offset types on
Offset.Set()
(#962, @jdockerty). - Added example for using rebalance callback with manual commit.
confluent-kafka-go is based on librdkafka v2.1.0, see the librdkafka v2.1.0 release notes and later ones for a complete list of changes, enhancements, fixes and upgrade considerations.