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

Posted to dev@kafka.apache.org by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/09/04 20:59:00 UTC

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

     [ https://issues.apache.org/jira/browse/KAFKA-7211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dong Lin resolved KAFKA-7211.
-----------------------------
    Resolution: Fixed

> 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
>            Assignee: huxihx
>            Priority: Major
>             Fix For: 2.1.0
>
>
> 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)