lianetm commented on code in PR #16673:
URL: https://github.com/apache/kafka/pull/16673#discussion_r1722215526
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerUtils.java:
##########
@@ -231,6 +231,8 @@ public static <T> T getResult(Future<T> future) {
try {
return future.get();
} catch (ExecutionException e) {
+ if (e.getCause() instanceof IllegalStateException)
Review Comment:
interesting, good catch by the integration test. The trick is that this
would of course apply to all calls, not only to the assign, but feels like the
right thing to ensure we propagate an IllegalState as such, and not obfuscated
in a KafkaException.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
