[GitHub] [kafka] rajinisivaram commented on a change in pull request #9406: KAFKA-10520; Ensure transactional producers poll if leastLoadedNode not available with max.in.flight=1

[GitBox]

rajinisivaram commented on a change in pull request #9406:
URL: https://github.com/apache/kafka/pull/9406#discussion_r510009333



##########
File path: 
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java
##########
@@ -2667,4 +2760,43 @@ private void assertFutureFailure(Future<?> future, 
Class<? extends Exception> ex
         }
     }
 
+    private void createMockClientWithMaxFlightOneMetadataPending() {
+        client = new MockClient(time, metadata) {

Review comment:
       @hachikuji Thanks for reviewing and merging! I have opened 
https://issues.apache.org/jira/browse/KAFKA-10626 to add max.in.flight to 
MockClient. 




----------------------------------------------------------------
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