TaiJuWu opened a new pull request, #19105: URL: https://github.com/apache/kafka/pull/19105
Jira: https://issues.apache.org/jira/browse/KAFKA-18031 This test expose an issue: If the request number exceeds `maxInFlightRequestsPerConnection`, the `LeaveGroup` request would be not sent in time. I do follow change: 1. Allow `LeaveGroup` request to send even if the `InFlightRequest` meet the max number. 2. Move `MaybeThrowInterrupt` to the end of `ConsumerNetwork.poll` 3. For test, honor the close time instead of default value, this can make this test more stable. -- 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
