« Changelog History


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.

    ✨ Enhancements

    • go.delivery.report.fields=all,key,value,none can now be used to avoid copying message key and/or value to the delivery report, improving performance in high-throughput applications (by @kevinconaway).

    🛠 Fixes

    • Consumer.Close() previously did not trigger the final RevokePartitions callback, this is now fixed.