ijuma commented on a change in pull request #9878:
URL: https://github.com/apache/kafka/pull/9878#discussion_r663961964
##
File path:
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java
##
@@ -267,50 +180,82 @@ public T get() throws InterruptedExceptio
ijuma commented on a change in pull request #9878:
URL: https://github.com/apache/kafka/pull/9878#discussion_r663961964
##
File path:
clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java
##
@@ -267,50 +180,82 @@ public T get() throws InterruptedExceptio