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

MM should handle timeouts in commitSync

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.1.0
    • Component/s: None
    • Labels:
      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

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: