Jason Gustafson created KAFKA-7211:
--------------------------------------

             Summary: MM should handle timeouts in commitSync
                 Key: KAFKA-7211
                 URL: https://issues.apache.org/jira/browse/KAFKA-7211
             Project: Kafka
          Issue Type: Improvement
            Reporter: Jason Gustafson


Now that we have KIP-266, the user can override `default.api.timeout.ms` for 
the consumer so that commitSync does not block indefinitely. MM needs to be 
updated to handle TimeoutException. We may also need some logic to handle 
deleted topics. If MM attempts to commit an offset for a deleted topic, the 
call will timeout and we should probably check if the topic exists and remove 
the offset if it doesn't.





--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to