splett2 opened a new pull request, #15565: URL: https://github.com/apache/kafka/pull/15565
### What On a client-side triggered request timeout (the client did not receive a response from the server in a timely manner), the client needs to refresh metadata. This requires the partition response passed to `completeBatch` to be an `instanceof InvalidMetadataException`. This is slightly different than Errors.REQUEST_TIMED_OUT, since the latter is returned when the HWM fails to advance within the configured request timeout threshold, so we do not want to make `REQUEST_TIMED_OUT` an invalid metadata exception. I couldn't find a better fit than NETWORK_EXCEPTION, so hopefully the improved logging from KAFKA-14317 still reasonably distinguishes between request timeouts and sudden connection interrupts. ### Testing Added a unit test in `SenderTest` using ### 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
