Philip Nee created KAFKA-15475:
----------------------------------

             Summary: Timeout request might retry forever even if the user API 
times out in AsyncConsumer
                 Key: KAFKA-15475
                 URL: https://issues.apache.org/jira/browse/KAFKA-15475
             Project: Kafka
          Issue Type: Bug
          Components: consumer
            Reporter: Philip Nee
            Assignee: Philip Nee


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)

Reply via email to