Confluent's Apache Kafka Golang client
This is a feature release.
DescribeCluster()
and DescribeTopics()
(#964, @jainruchir).Rack
to the Node
type, so AdminAPI calls can expose racks for brokers (currently, all Describe Responses) (#964, @jainruchir).GetSchemaMetadata
(#1042).CreateTopic
method to the MockCluster. (#1047, @mimikwang).HTTPS_PROXY
environment variable, if set, for the Schema Registry client (#1065, @finncolman).DescribeTopics
function (#1068).testing
was being imported by a non-test file, testhelpers.go. (#1049, @dmlambea).Coordinator
field in ConsumerGroupDescription
in case it's not known. It now contains a Node
with ID -1 in that case. Avoids a C segmentation fault.Producer.Flush
. It was waiting for queue.buffering.max.ms
while flushing (#1013).confluent-kafka-go is based on librdkafka v2.3.0, see the librdkafka v2.3.0 release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
This is a feature release.
Serializer.Serialize()
, caused due to an unchecked error (#997, @baganokodo2022).nil
slice in AdminClient.ListConsumerGroupOffsets
, when earlier it was not processing that correctly (#985, @alexandredantas).confluent-kafka-go is based on librdkafka v2.2.0, see the librdkafka v2.2.0 release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
This is a maintenance release.
It is strongly recommended to update to v2.1.1 if v2.1.0 is being used, as it fixes a critical issue in the consumer (#980).
confluent-kafka-go is based on librdkafka v2.1.1, see the librdkafka v2.1.1 release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
This is a feature release.
SeekPartitions()
method to seek multiple partitions at once and deprecated Seek()
(#940).Offset.Set()
(#962, @jdockerty).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.
This is a feature release:
SetSaslCredentials
. This new method (on the Producer, Consumer, and AdminClient) allows modifying the stored SASL PLAIN/SCRAM credentials that will be used for subsequent (new) connections to a broker (#879).ProduceChannel()
) and channel based consumer (Consumer Events()
) are deprecated (#894).IsTimeout()
on Error type. This is a convenience method that checks if the error is due to a timeout (#903).Seek()
is now ignored and an infinite timeout is used, the method will block until the fetcher state is updated (typically within microseconds) (#906)ListConsumerGroups
Admin operation. Supports listing by state.DescribeConsumerGroups
Admin operation. Supports multiple groups.DeleteConsumerGroups
Admin operation. Supports multiple groups (@vsantwana).ListConsumerGroupOffsets
Admin operation. Currently, only supports 1 group with multiple partitions. Supports the requireStable option.AlterConsumerGroupOffsets
Admin operation. Currently, only supports 1 group with multiple offsets.SetRoundtripDuration
to the mock broker for setting RTT delay for a given mock broker (@kkoehler, #892).SpecificDeserializer.Deserialize
method was not returning its result correctly, and was hence unusable. The return has been fixed (#849).SerializerConfig
, was ignored. It is now used as expected (@perdue, #870).nil
pointer, fixed with proper initialization (@HansK-p, @ju-popov, #878).confluent-kafka-go is based on librdkafka v2.0.2, see the librdkafka v2.0.0 release notes and later ones for a complete list of changes, enhancements, fixes and upgrade considerations.
Note: There were no confluent-kafka-go v2.0.0 or v2.0.1 releases.
v1.9.2 is a maintenance release:
confluent-kafka-go is based on librdkafka v1.9.2, see the librdkafka release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
v1.9.1 is a feature release:
Schema Registry support for Avro Generic and Specific, Protocol Buffers and JSON Schema. (@rayokota, #776).
Built-in support for Mac OSX M1 / arm64. (#818).
confluent-kafka-go is based on librdkafka v1.9.1, see the librdkafka release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
v1.9.0 is a feature release:
confluent-kafka-go is based on librdkafka v1.9.0, see the librdkafka release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
This is a maintenance release:
confluent-kafka-go is based on librdkafka v1.8.2, see the librdkafka release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
Note: There were no confluent-kafka-go v1.8.0 and v1.8.1 releases.
confluent-kafka-go is based on librdkafka v1.7.0, see the librdkafka release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
Message.Headers
if the Producer's go.delivery.report.fields
configuration property is set to include headers
, e.g.:
"go.delivery.report.fields": "key,value,headers"
This comes at a performance cost and are thus disabled by default.