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

    •,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.