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)