[KAFKA-15562] Ensure fetch offset and commit offset handler handles both timeout and various error types - ASF JIRA

XML

Word

Printable

JSON

Both fetchOffsetRequest and commitOffsetRequest handlers don't have sufficient logic to handle timeout exception.

CommitOffsetRequest handler also doesn't handle various of server error such as coordinator not found. We need to handle:

If Exception is non null:

- handle RetriableError that respects requestTimeoutMs

- handle NonRetriableError

If the response contains error, ensure to:

- mark coordinator unknown if needed

- retry if needed

- fail the request

links to

GitHub Pull Request #14639