tombentley commented on a change in pull request #8311:
URL: https://github.com/apache/kafka/pull/8311#discussion_r420644795
##########
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##########
@@ -1402,6 +1407,15 @@ int numPendingCalls() {
return runnable.pendingCalls.size();
}
+ /**
+ * Fail the given future when a response handler expected a result for an
entity but no result was present.
+ * @param future The future to fail.
+ * @param message The message to fail the future with
+ */
+ private void partialResponse(KafkaFutureImpl<?> future, String message) {
Review comment:
I agree it's not doing much. What value it has is in trying to handle
these cases in a consistent way, and being able to more easily discover/reason
about the call sites. Maybe something like `invalidBrokerResponse()` would be a
better name? But if you don't like that I'm happy to remove it.
----------------------------------------------------------------
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
