Confluent Kafka Golang Client v1.6.1 Release Notes
🚀 v1.6.1 is a feature release:
- KIP-429: Incremental consumer rebalancing - see [cooperative_consumer_example.go](examples/cooperative_consumer_example/cooperative_consumer_example.go) for an example how to use the new incremental rebalancing consumer.
- KIP-480: Sticky producer partitioner - increase throughput and decrease latency by sticking to a single random partition for some time.
- KIP-447: Scalable transactional producer - a single transaction producer can now be used for multiple input partitions.
👀 confluent-kafka-go is based on and bundles librdkafka v1.6.1, see the 🚀 librdkafka release notes ⬆️ for a complete list of changes, enhancements, fixes and upgrade considerations.
go.delivery.report.fields=all,key,value,nonecan now be used to avoid copying message key and/or value to the delivery report, improving performance in high-throughput applications (by @kevinconaway).
- Consumer.Close() previously did not trigger the final RevokePartitions callback, this is now fixed.