Page History

...

With KIP-74, we now have a good way to limit the size of fetch responses, but it may still be difficult for users to control overall memory since the consumer will send fetches in parallel to all the brokers which own partitions that it is subscribed to. To give users finer control, it might make sense to add a `max.in.flightinflight.fetches` setting to limit the total number of concurrent fetches at any time.

...

The following option will be added for consumers to configure (in ConsumerConfigs.java):

1. max.in.flightinflight.fetches (Integer) Specifies the maximum number of in-flight fetches the consumer can make. Defaults to Integer.MAX_VALUE.

...