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

Handle Connect WorkerTask shutdown before startup correctly

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.10.0.0
    • Component/s: KafkaConnect
    • Labels:
      None

      Description

      This is a follow-up from KAFKA-3092. The shortcut exit from awaitShutdown() in WorkerTask can lead to an inconsistent state if the task has not actually begun execution yet. Although the caller will believe the task has completed shutdown, nothing stops it from starting afterwards. This could happen if there is a long delay between the time a task is submitted to an Executor and the time it begins execution.

        Attachments

          Activity

            People

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

              Dates

              • Created:
                Updated:
                Resolved: