search

confluentinc / confluent-kafka-go

Confluent's Apache Kafka Golang client
Apache License 2.0
4.67k stars 659 forks source link

Bug with v2.6.0 during version negotiation. #1320

Closed misalcedo closed 6 days ago

misalcedo commented 1 month ago

When we use version 2.6.0, the api version negotation fails to correctly set the fetch request's version to something the server supports. We use an internal Redis-backed implementation of Kafka for testing in Docker containers that only supports up to v7 of the Fetch request. However, the newest client fails to select the correct version and instead sends v12 for fetch requests.

The same problem occurred on our production Kafka cluster running Kafka version 2.6.1 with a TLS connection. All other interactions between the consumer and the cluster seemed to work correctly.

The problem does not occur when we use version 2.5.3.

milindl commented 1 month ago

Thanks for filing this, we fixed it here: https://github.com/confluentinc/librdkafka/pull/4871 . The fixed version is not released yet.

misalcedo commented 1 month ago

Thank you so much for fixing it so quickly. I look forward to having a new release that includes the fix.

misalcedo commented 6 days ago

This was fixed in 2.6.1