...

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

Proposed Changes

Update Fetcher.java to take into account check the number of existing in-flight fetches (this is already tracked by numInFlightFetches) before initiating a new fetch request. The number of in-flight fetches is already trackedrequests in createFetches().

Compatibility, Deprecation, and Migration Plan

...