Emanuele Sabellico

and used an exclusive lock The read lock alone is requested only when the key is not in cache and multiple Get requests are made concurrently. The ToMap method is...

changed copyright years, owner and urls

[KIP-601] Increase connection timeout

2

being closer to the defaults in KIP-601. In KafkaJS the connection establishment limit corresponds to the `connectionTimeout` + `authenticationTimeout`. `authenticationTimeout` has been increased to 10s, but `connectionTimeout` is 1s. KIP-601...

failover issue with schema-registry behind reverse proxy

4

Hi, I've noticed that when the schema registry is behind a reverse proxy like nginx and we have configured multiple schema registry url like schema.registry.url=http://x.x.x.1/api/schema-registry/,http://x.x.x.2/api/schema-registry/,http://x.x.x.3/api/schema-registry/ if the first schema registry...

Improve rebalance example by simulating a user transaction an random failures

1

to show how it must behave

Exactly once semantics basic implementation example

4

This is the example used to test long running EOS tests during the development of this librdkafka [fix](https://github.com/edenhill/librdkafka/pull/3971). It contains the needed checks for retriable, abortable or fatal error the...