apoorvmittal10 opened a new pull request, #20253: URL: https://github.com/apache/kafka/pull/20253
The PR restricts the records being acquired post max-inflight limit. Previously the max in-flight limit was only enforced while considering the share partition for further fetches i.e. once the limit was reached the share partition was not considered for further fetches. However, when the records are actively released then there might be some records being acquired post max-inflight limit. This is evident with higher number of consumers reading from same share partition and releasing the records. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
