Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-7211

MM should handle timeouts in commitSync

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 2.1.0
    • None
    • None

    Description

      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.

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #5492

          Activity

            People

              huxi_2b huxihx
              hachikuji Jason Gustafson
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: