Changelog History
Page 1
-
v1.6.1 Changes
๐ 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.
-
v1.5.2 Changes
November 05, 2020confluent-kafka-go v1.5.2
๐ v1.5.2 is a maintenance release with the following fixes and enhancements:
- ๐ Bundles librdkafka v1.5.2 - see release notes for all enhancements and fixes.
- ๐ Documentation fixes
๐ confluent-kafka-go is based on librdkafka v1.5.2, see the
๐ librdkafka release notes
โฌ๏ธ for a complete list of changes, enhancements, fixes and upgrade considerations. -
v1.4.2 Changes
May 07, 2020confluent-kafka-go v1.4.2
๐ v1.4.2 is a maintenance release:
- The bundled librdkafka directory (
kafka/librdkafka
) is no longer pruned by Go mod vendor import. - โฌ๏ธ Bundled librdkafka upgraded to v1.4.2, highlights:
- System root CA certificates should now be picked up automatically on most platforms
- Fix produce/consume hang after partition goes away and comes back,
such as when a topic is deleted and re-created (regression in v1.3.0).
librdkafka v1.4.2 changes
๐ See the librdkafka v1.4.2 release notes for changes to the bundled librdkafka included with the Go client.
- The bundled librdkafka directory (
-
v1.4.0 Changes
April 08, 2020confluent-kafka-go v1.4.0
- Added Transactional Producer API and full Exactly-Once-Semantics (EOS) support.
- A prebuilt version of the latest version of librdkafka is now bundled with the confluent-kafka-go client. A separate installation of librdkafka is NO LONGER REQUIRED or used.
- โ Added support for sending client (librdkafka) logs to
Logs()
channel. - โ Added
Consumer.Position()
to retrieve the current consumer offsets. - The
Error
type now has additional attributes, such asIsRetriable()
to deem if the errored operation can be retried. This is currently only exposed for the Transactional API. - โ Removed support for Go < 1.9
Transactional API
๐ librdkafka and confluent-kafka-go now has complete Exactly-Once-Semantics (EOS) functionality, supporting the idempotent producer (since v1.0.0), a transaction-aware consumer (since v1.2.0) and full producer transaction support (in this release).
This enables developers to create Exactly-Once applications with Apache Kafka.๐ See the Transactions in Apache Kafka page for an introduction and check the transactions example for a complete transactional application example.
Bundled librdkafka
The confluent-kafka-go client now comes with batteries included, namely prebuilt versions of librdkafka for the most popular platforms, you will thus no longer need to install or manage librdkafka separately.
๐ Supported platforms are:
- Mac OSX
- ๐ง glibc-based Linux x64 (e.g., RedHat, Debian, etc) - lacks Kerberos/GSSAPI support
- ๐ง musl-based Linux x64 (Alpine) - lacks Kerberos/GSSAPI support
๐ง These prebuilt librdkafka has all features (e.g., SSL, compression, etc) except for the Linux builds which due to libsasl2 dependencies does not have Kerberos/GSSAPI support.
๐ If you need Kerberos support, or you are running on a platform where the prebuilt librdkafka builds are not available (see above), you will need to install librdkafka separately (preferably through the Confluent APT and RPM repositories) and build your application with-tags dynamic
to disable the builtin librdkafka and instead link your application dynamically to librdkafka.librdkafka v1.4.0 changes
๐ Full librdkafka v1.4.0 release notes.
Highlights:
- KIP-98: Transactional Producer API
- KIP-345: Static consumer group membership (by @rnpridgeon)
- KIP-511: Report client software name and version to broker
- ๐ SASL SCRAM security fixes.
-
v1.4.0-RC1
April 08, 2020 -
v1.3.0 Changes
December 17, 2019confluent-kafka-go v1.3.0
Purge messages API (by @khorshuheng at GoJek).
ClusterID and ControllerID APIs.
๐ Go Modules support.
๐ Fixed memory leak on calls to
NewAdminClient()
. (discovered by @gabeysunda)Requires librdkafka v1.3.0 or later
librdkafka v1.3.0 changes
๐ Full librdkafka v1.3.0 release notes.
- KIP-392: Fetch messages from closest replica/follower (by @mhowlett).
- โ Experimental mock broker to make application and librdkafka development testing easier.
- ๐ Fixed consumer_lag in stats when consuming from broker versions <0.11.0.0 (regression in librdkafka v1.2.0).
-
v1.1.0 Changes
July 15, 2019confluent-kafka-go v1.1.0
- โ OAUTHBEARER SASL authentication (KIP-255) by Ron Dagostini (@rondagostino) at StateStreet.
- ๐ Offset commit metadata (@damour, #353)
- Requires librdkafka v1.1.0 or later
Noteworthy librdkafka v1.1.0 changes
๐ Full librdkafka v1.1.0 release notes.
- โ SASL OAUTHBEARER support (by @rondagostino at StateStreet)
- ๐ In-memory SSL certificates (PEM, DER, PKCS#12) support (by @noahdav at Microsoft)
- ๐ Pluggable broker SSL certificate verification callback (by @noahdav at Microsoft)
- ๐ Use Windows Root/CA SSL Certificate Store (by @noahdav at Microsoft)
- 0๏ธโฃ
ssl.endpoint.identification.algorithm=https
(off by default) to validate the broker hostname matches the certificate. Requires OpenSSL >= 1.0.2. - ๐ Improved GSSAPI/Kerberos ticket refresh
โฌ๏ธ Upgrade considerations
- ๐ Windows SSL users will no longer need to specify a CA certificate file/directory (
ssl.ca.location
), librdkafka will load the CA certs by default from the Windows Root Certificate Store. - 0๏ธโฃ SSL peer (broker) certificate verification is now enabled by default (disable with
enable.ssl.certificate.verification=false
) - ๐
%{broker.name}
is no longer supported insasl.kerberos.kinit.cmd
since kinit refresh is no longer executed per broker, but per client instance.
SSL
๐ New configuration properties:
ssl.key.pem
- client's private key as a string in PEM formatssl.certificate.pem
- client's public key as a string in PEM format- 0๏ธโฃ
enable.ssl.certificate.verification
- enable(default)/disable OpenSSL's builtin broker certificate verification. - 0๏ธโฃ
enable.ssl.endpoint.identification.algorithm
- to verify the broker's hostname with its certificate (disabled by default). - The private key data is now securely cleared from memory after last use.
โจ Enhancements
- โฌ๏ธ Bump
message.timeout.ms
max value from 15 minutes to 24 days (@sarkanyi)
๐ Fixes
- SASL GSSAPI/Kerberos: Don't run kinit refresh for each broker, just per client instance.
- SASL GSSAPI/Kerberos: Changed
sasl.kerberos.kinit.cmd
to first attempt ticket refresh, then acquire. - SASL: Proper locking on broker name acquisition.
- ๐ Consumer:
max.poll.interval.ms
now correctly handles blocking poll calls, allowing a longer poll timeout than the max poll interval.
-
v1.1.0-RC1
July 15, 2019 -
v1.0.0 Changes
March 29, 2019confluent-kafka-go v1.0.0
๐ This release adds support for librdkafka v1.0.0, featuring the EOS Idempotent Producer, Sparse connections, KIP-62 -
max.poll.interval.ms
support, zstd, and more.๐ See the librdkafka v1.0.0 release notes for more information and upgrade considerations.
Go client enhancements
- Now requires librdkafka v1.0.0.
- A new
IsFatal()
function has been added toKafkaError
to help the application differentiate between temporary and fatal errors. Fatal errors are currently only triggered by the idempotent producer.
- โ Added
kafka.NewError()
to make it possible to create error objects from user code / unit test (Artem Yarulin)๐ Go client fixes
- ๐ง Deprecate the use of
default.topic.config
. Topic configuration should now be set on the standard ConfigMap. - Reject delivery.report.only.error=true on producer creation (#306)
- ๐ Avoid use of "Deprecated: " prefix (#268)
- PartitionEOF must now be explicitly enabled thru
enable.partition.eof
Make sure to check out the Idempotent Producer example
-
v1.0.0-RC1
March 27, 2019