modify default value of max.in.flight.requests.per.connection

[Stephan14]

The default value of max.in.flight.requests.per.connection is 1000000, can we modify the value to 5? The default value on other sdk is 5.

[milindl]

You can change the value using the configuration max.in.flight.requests.per.connection - see config reference here, but what is the purpose of making the change? At the moment we handle producing multiple partitions to the same broker a bit differently from Java which sometimes means that this limit needs to be higher for performance.

[Stephan14]

When using the confluent-kafka-go SDK, if the max.in.flight.requests.per.connection configuration is set to 1,000,000, the client will send an excessive number of requests to the Kafka broker. This causes the Kafka broker's network threads to become quite busy, thereby affecting the production and consumption operations of other clients.