github confluentinc/confluent-kafka-go v2.15.1

5 hours ago

Fixes

  • Preserve HTTP status on Schema Registry error responses (#1590)
  • Fix Consumer.Close() hanging indefinitely when the consumer has a fatal
    error (e.g. FENCED_INSTANCE_ID). The error returned by
    rd_kafka_consumer_close_queue() was being discarded, leaving Close()
    polling for a close that was never started (#1588, @nolansherman-spoton)

confluent-kafka-go is based on librdkafka 2.15.1, see the
librdkafka 2.15.1 release notes
for a complete list of changes, enhancements, fixes and upgrade considerations.

Don't miss a new confluent-kafka-go release

NewReleases is sending notifications on new releases.