[jira] [Created] (KAFKA-10087) Properly throw LogTruncation exception from OffsetForLeaderEpoch future

["Boyang Chen (Jira)" <ji...@apache.org>]

Boyang Chen created KAFKA-10087:
-----------------------------------

             Summary: Properly throw LogTruncation exception from OffsetForLeaderEpoch future
                 Key: KAFKA-10087
                 URL: https://issues.apache.org/jira/browse/KAFKA-10087
             Project: Kafka
          Issue Type: Bug
            Reporter: Boyang Chen
            Assignee: Boyang Chen


For OffsetForLeaderEpoch#onSuccess, we could throw either OffsetOutOfRange or LogTruncation exceptions, which are swallowed by the AsyncClient logic:
try {
    future.complete(handleResponse(node, requestData, resp));
} catch (RuntimeException e) {
    if (!future.isDone()) {
        future.raise(e);
    }
}
We should fix the exception case to throw it to the upstream. In the meantime, we should ensure that any discard exception case gets retried eventually for LeaderOffset call.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)