apoorvmittal10 opened a new pull request, #17821: URL: https://github.com/apache/kafka/pull/17821
The completable future exceptions can be wrapped either in CompletionException or ExectionException or CancellationException. The method currently unwraps first 2. In the recent commit https://github.com/apache/kafka/pull/17409, though there is other JDK issue, but we have added support for unwrapping CancellationException as well. Not all code in Kafka uses KafkaFutureImpl rather a lot also use CompletableFuture directly. Where the unwrapping of exception is missing CancellationException type. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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