v2.1.0
版本发布时间: 2023-04-06 17:12:30
confluentinc/confluent-kafka-go最新发布版本:v2.3.0(2023-10-25 23:55:38)
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.