You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Jason Gustafson (JIRA)" <ji...@apache.org> on 2018/07/26 18:11:00 UTC

[jira] [Created] (KAFKA-7211) MM should handle timeouts in commitSync

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)