dimitarndimitrov commented on code in PR #13432:
URL: https://github.com/apache/kafka/pull/13432#discussion_r1163915187
##########
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java:
##########
@@ -260,12 +261,18 @@ public void onFailure(
.filter(future.lookupKeys()::contains)
.collect(Collectors.toSet());
retryLookup(keysToUnmap);
+ } else if (t instanceof UnsupportedVersionException) {
+ Map<K, Throwable> unrecoverableFailures =
+ handler.handleUnsupportedVersionException(
+ (UnsupportedVersionException) t,
+ spec.keys,
+ spec.scope instanceof FulfillmentScope);
Review Comment:
Yeah, that makes sense.
I initially thought about this but didn't want to expand on it too much
because then it might also make sense to compact it with the
`NoBatchedFindCoordinatorsException`/`NoBatchedOffsetFetchRequestException`
case slightly above, so I was concerned that that many changes unrelated to the
ListOffsets API might be undesirable.
--
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.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
