confluentinc/confluent-kafka-go v2.1.0

on GitHub

This is a feature release.

• Added Consumer SeekPartitions() method to seek multiple partitions at once and deprecated Seek() (#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.