Emanuele Sabellico
Emanuele Sabellico
@adawaefve giving that you're working with Docker could you provide a Dockerfile to reproduce it
Hi, what is your Kafka version and broker configuration of `offsets.retention.minutes`? Before v2.x if was 1 day by default and would lose the group committed offsets after that period of...
Thanks @dpcollins-google! @edenhill left the company and transferred ownership of the repository to Confluent, that is maintaining it. I'm checking this.
The java code your're linking isn't about nodeId to Node mapping, but refers to [KIP-516](https://cwiki.apache.org/confluence/display/KAFKA/KIP-516%3A+Topic+Identifiers) that introduces topic ids (still not implemented in librdkafka), instead the place where the nodeId...
In that code the newNodes parameter is not touched and passed to the MetadataCache constructor, instead you have a map from topic name to topic id. It's about KIP-516. Indeed...
The first request that is done is [ApiVersions](https://kafka.apache.org/protocol.html#The_Messages_ApiVersions), there is no topic there. You could achieve the same by putting the broker id in the hostname and running a SNI...
Closed in https://github.com/confluentinc/librdkafka/pull/4557
That's only for Windows because we use the LTS version of OpenSSL 3.0.x and that's not updated in vcpkg https://vcpkg.io/en/package/openssl we can think about using the non-LTS version for window...
In CKJS the max poll interval that is passed is the double of what's configured. Because of the cache it has to maintain. Given in CKJS the user isn't calling...
Closed by #4706