mimaison commented on a change in pull request #10743:
URL: https://github.com/apache/kafka/pull/10743#discussion_r649213934
##########
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##########
@@ -858,6 +885,12 @@ public void onSuccess(ClientResponse resp,
RequestFuture<Void> future) {
public void onFailure(RuntimeException e, RequestFuture<Void> future) {
log.debug("FindCoordinator request failed due to {}",
e.toString());
+ if (e instanceof UnsupportedBatchLookupException) {
Review comment:
I've only taken a very brief look and I think this approach would work
well for Connect, Producer and Consumer, however it's a bit more complicated
with Admin.
In Admin, requests are built by lookup strategies. Lookups can be sent to
any broker so knowing the max version for a specific call is not completely
trivial. That said, it's not impossible either so if there's concensus it would
be preferable I can give that a try.
--
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
