mumrah commented on pull request #9749: URL: https://github.com/apache/kafka/pull/9749#issuecomment-758679230
It seems I over-complicated this while trying to avoid clearing the inflight in the response handler when another request needs to go out. I think what you suggest does work. If the response handler just immediately sets the inflight flag to false it doesn't matter if another `submit` call races with checking the queue size since one of them will set the inflight flag true and the request will get submitted. I'll go ahead and try this out ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org