[ https://issues.apache.org/jira/browse/KAFKA-7211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dong Lin updated KAFKA-7211: ---------------------------- Fix Version/s: 2.1.0 > 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)