[
https://issues.apache.org/jira/browse/KAFKA-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804921#comment-17804921
]
Kirk True commented on KAFKA-15475:
-----------------------------------
[~lianetm] / [~pnee] —I need to refresh my memory about what it means for an
exception to be retriable. Does it mean that the operation is automatically
retried at some layer of the client, or does it simply mean that it's a
transient failure that the caller _could_ retry, if desired?
> Timeout request might retry forever even if the user API times out in
> PrototypeAsyncConsumer
> --------------------------------------------------------------------------------------------
>
> Key: KAFKA-15475
> URL: https://issues.apache.org/jira/browse/KAFKA-15475
> Project: Kafka
> Issue Type: Bug
> Components: clients, consumer
> Reporter: Philip Nee
> Assignee: Philip Nee
> Priority: Minor
> Labels: consumer-threading-refactor, kip-848-preview
> Fix For: 3.8.0
>
>
> If the request timeout in the background thread, it will be completed with
> TimeoutException, which is Retriable. In the TopicMetadataRequestManager and
> possibly other managers, the request might continue to be retried forever.
>
> There are two ways to fix this
> # Pass a timer to the manager to remove the inflight requests when it is
> expired.
> # Pass the future to the application layer and continue to retry.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
